From f3d442ae21477a0edc14dbc89201cc61e5313286 Mon Sep 17 00:00:00 2001
From: Gabe Joseph <gjoseph92@gmail.com>
Date: Tue, 15 Mar 2022 10:19:38 -0600
Subject: [PATCH] Make log_event threadsafe

Closes #5552
---
 distributed/worker.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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