Skip to content

Commit

Permalink
reinstante the await self in handle_comm
Browse files Browse the repository at this point in the history
If not awaited, the server might server handlers before the server is
properly initialized. For instance plugins and preload modules might
not be fully loaded before that happens
  • Loading branch information
fjetter committed Jul 8, 2021
1 parent a7100c0 commit 353bd34
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions distributed/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -438,6 +438,10 @@ async def handle_comm(self, comm):
logger.debug("Connection from %r to %s", address, type(self).__name__)
self._comms[comm] = op

# The server might already be listening even though it is not properly
# started, yet. (e.g. preload modules not done)
await self

try:
while True:
try:
Expand Down

0 comments on commit 353bd34

Please sign in to comment.