fix: sync engine fails on startup

michaelfeil · Jun 23, 2024 · 38012d0 · 38012d0
1 parent d85dac3
commit 38012d0
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/libs/infinity_emb/infinity_emb/sync_engine.py b/libs/infinity_emb/infinity_emb/sync_engine.py
@@ -101,8 +101,13 @@ def async_run(
 class SyncEngineArray(AsyncLifeMixin):
     def __init__(self, _engine_args_array: list[EngineArgs]):
         super().__init__()
-        self.async_engine_array = AsyncEngineArray.from_args(_engine_args_array)
-        self.async_run(self.async_engine_array.astart).result()
+        try:
+            self.async_engine_array = AsyncEngineArray.from_args(_engine_args_array)
+            self.async_run(self.async_engine_array.astart).result()
+        except Exception as e:
+            self.async_close_loop()
+            raise e
+
 
     @classmethod
     def from_args(cls, engine_args_array: list[EngineArgs]) -> "SyncEngineArray":