You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
# We use gen.coroutine here rather than async def to avoid errors like
# Task was destroyed but it is pending!
# Triggered by distributed.deploy.tests.test_local::test_silent_startup
this Task was destroyed but it is pending! warning message is due to loop.stop() being called before all the tasks are finished. When using asyncio.run all tasks are cancelled and the loop only stops when all the tasks are finished and so this error should no longer happen.
most functions that use
@gen.coroutine
were upgraded in #3706 #3242 #2934 and #2871 however there's still a few leftnotably
distributed/distributed/comm/tcp.py
Lines 330 to 334 in f4c52e9
this
Task was destroyed but it is pending!
warning message is due toloop.stop()
being called before all the tasks are finished. When usingasyncio.run
all tasks are cancelled and the loop only stops when all the tasks are finished and so this error should no longer happen.see also #3245
Soft blocked by: Usage of asyncio.run
The text was updated successfully, but these errors were encountered: