FIX: Fix multiple calls to start live thread

databento · Aug 16, 2024 · b1c06b4 · b1c06b4
1 parent 9954f73
commit b1c06b4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -7,6 +7,7 @@
 
 #### Bug fixes
 - Fixed an issue receiving multiple DBN v1 `ErrorMsg` in the `Live` client would cause an `InvalidState` error
+- Fixed an issue where creating `Live` clients in multiple threads could cause a `RuntimeError` upon initialization
 
 ## 0.39.2 - 2024-08-13
 

diff --git a/databento/live/client.py b/databento/live/client.py
@@ -61,6 +61,7 @@ class Live:
     """
 
     _loop = asyncio.new_event_loop()
+    _lock = threading.Lock()
     _thread = threading.Thread(
         target=_loop.run_forever,
         name="databento_live",
@@ -109,8 +110,9 @@ def __init__(
 
         self._session._user_callbacks.append((self._map_symbol, None))
 
-        if not Live._thread.is_alive():
-            Live._thread.start()
+        with Live._lock:
+            if not Live._thread.is_alive():
+                Live._thread.start()
 
     def __del__(self) -> None:
         try: