search

dask / distributed

A distributed task scheduler for Dask
https://distributed.dask.org
BSD 3-Clause "New" or "Revised" License
1.57k stars 718 forks source link

Couroutine scheduler.start was never awaited #2895

Closed dickreuter closed 5 years ago

dickreuter commented 5 years ago

I noticed that with the latest master there have been some changes and I can no longer do this to run the scheduler (or similar for worker):

scheduler=Scheduler()
scheduler.start()
loop=IOLoop.current()
loop.start()

because I get a warning: Runtimewarning: couroutine 'Scheduler.start' was never awaited scheduler.start()

Any suggestions what changes have been made since last month that would cause this? many thanks

mrocklin commented 5 years ago

Thanks for the reminder. Fixed in https://github.com/dask/dask/pull/5163

On Sat, Jul 27, 2019 at 10:04 AM Nicolas Dickreuter < notifications@github.com> wrote:

I noticed that with the latest master there have been some changes and I can no longer do this to run the scheduler (or similar for worker):

scheduler=Scheduler() scheduler.start() loop=IOLoop.current() loop.start()

because I get a warning: Runtimewarning: couroutine 'Scheduler.start' was never awaited scheduler.start()

Any suggestions what changes have been made since last month that would cause this? many thanks

— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub https://github.com/dask/distributed/issues/2895?email_source=notifications&email_token=AACKZTEIIK3XLATI5VNU7HLQBR52PA5CNFSM4IHJ65A2YY3PNVWWK3TUL52HS4DFUVEXG43VMWVGG33NNVSW45C7NFSM4HB3OHUA, or mute the thread https://github.com/notifications/unsubscribe-auth/AACKZTHV3NDTYNTHVT4RSVLQBR52PANCNFSM4IHJ65AQ .