diff --git a/distributed/nanny.py b/distributed/nanny.py index a248c08cb19..fcff077a8d6 100644 --- a/distributed/nanny.py +++ b/distributed/nanny.py @@ -951,7 +951,7 @@ async def run() -> None: # Otherwise we arrive in a race condition where the process # cleanup wipes the queue before the exception can be # properly handled. See also - # WorkerProcess._wait_until_connected (the 2 is for good + # WorkerProcess._wait_until_connected (the 3 is for good # measure) sync_sleep(cls._init_msg_interval * 3)