diff --git a/python/xoscar/backends/indigen/pool.py b/python/xoscar/backends/indigen/pool.py index ae34a899..9f151a0e 100644 --- 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}", )