Make log_event threadsafe (#5946)

dask · Mar 16, 2022 · 3492ef1 · 3492ef1
1 parent 6083385
commit 3492ef1
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