diff --git a/distributed/worker.py b/distributed/worker.py
index 50fc33795e1..918f01d2e5c 100644
--- 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