Make log_event threadsafe

Closes #5552
dask · Mar 15, 2022 · f3d442a · f3d442a
1 parent 7a69b5e
commit f3d442a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -922,12 +922,13 @@ def logs(self):
         return self._deque_handler.deque
 
     def log_event(self, topic, msg):
-        self.batched_stream.send(
+        self.loop.add_callback(
+            self.batched_stream.send,
             {
                 "op": "log-event",
                 "topic": topic,
                 "msg": msg,
-            }
+            },
         )
 
     @property