From e13e31aae9674c93675485bb9862c9d129b1fd6b Mon Sep 17 00:00:00 2001 From: tsukasa Date: Wed, 27 Sep 2023 17:53:03 +0800 Subject: [PATCH] fix queue compute node --- src/aios_kernel/queue_compute_node.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/aios_kernel/queue_compute_node.py b/src/aios_kernel/queue_compute_node.py index 7d88778..6d97446 100644 --- a/src/aios_kernel/queue_compute_node.py +++ b/src/aios_kernel/queue_compute_node.py @@ -56,7 +56,7 @@ class Queue_ComputeNode(ComputeNode): return result - async def start(self): + def start(self): if self.is_start is True: return self.is_start = True @@ -65,7 +65,7 @@ class Queue_ComputeNode(ComputeNode): while True: task = await self.task_queue.get() logger.info(f"openai_node get task: {task.display()}") - self._run_task(task) + await self._run_task(task) asyncio.create_task(_run_task_loop())