Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Allow a loop cycle after every message in the batch
Browse files Browse the repository at this point in the history
fjetter committed Oct 20, 2021
1 parent f3aa9d1 commit ba75e7c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion distributed/core.py
Original file line number Diff line number Diff line change
@@ -564,7 +564,7 @@ async def handle_stream(self, comm, extra=None, every_cycle=[]):
handler(**merge(extra, msg))
else:
logger.error("odd message %s", msg)
await asyncio.sleep(0)
await asyncio.sleep(0)

for func in every_cycle:
if is_coroutine_function(func):

0 comments on commit ba75e7c

Please sign in to comment.