Merge pull request #1381 from weaviate/grpc/patch-exception-handler-i…

…n-each-process-event-loop Ensure each per-process event loop has its exception handler patched properly
weaviate · Nov 1, 2024 · 63d7c6c · 63d7c6c
2 parents e004801 + 6bc9b39
commit 63d7c6c
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/weaviate/client.py b/weaviate/client.py
@@ -82,7 +82,6 @@ def __init__(
         self._event_loop = _EventLoopSingleton.get_instance()
         assert self._event_loop.loop is not None
         self._loop = self._event_loop.loop
-        _EventLoop.patch_exception_handler(self._loop)
 
         super().__init__(
             connection_params=connection_params,

diff --git a/weaviate/event_loop.py b/weaviate/event_loop.py
@@ -26,6 +26,7 @@ def start(self) -> None:
         if self.loop is not None:
             return
         self.loop = self.__start_new_event_loop()
+        _EventLoop.patch_exception_handler(self.loop)
 
     def run_until_complete(
         self, f: Callable[P, Coroutine[Any, Any, T]], *args: P.args, **kwargs: P.kwargs