BUG: append subpool logging (#77)

xorbitsai · Sep 14, 2023 · 30f4f4c · 30f4f4c
1 parent 17881dd
commit 30f4f4c
Showing 1 changed file with 1 addition and 11 deletions.
diff --git a/python/xoscar/backends/indigen/pool.py b/python/xoscar/backends/indigen/pool.py
@@ -289,16 +289,6 @@ async def _create_sub_pool(
             status_queue.put(process_status)
         await pool.join()
 
-    @classmethod
-    def _append_sub_pool(
-        cls,
-        config: ActorPoolConfig,
-        _process_index: int,
-        _status_queue: multiprocessing.Queue,
-    ):
-        coro = cls._create_sub_pool(config, _process_index, _status_queue)
-        asyncio.run(coro)
-
     async def append_sub_pool(
         self,
         label: str | None = None,
@@ -353,7 +343,7 @@ def start_pool_in_process():
 
             with _suspend_init_main():
                 process = ctx.Process(
-                    target=MainActorPool._append_sub_pool,
+                    target=self._start_sub_pool,
                     args=(self._config, process_index, status_queue),
                     name=f"IndigenActorPool{process_index}",
                 )