fix: workflow continue error

Author: zgqgit

src/backend/bisheng/chat/clients/workflow_client.py

@@ -129,7 +129,7 @@ async def check_status(self, message: dict, is_init: bool = False) -> (bool, str
 
     async def get_execute_worker(self) -> Optional[str]:
         if not self.hash_key:
-            return None
+            self.hash_key = self.chat_id if self.chat_id else generate_uuid()
         return await workflow_stateful_worker.find_task_node(self.hash_key)
 
     async def init_workflow(self, message: dict):
@@ -147,7 +147,6 @@ async def init_workflow(self, message: dict):
             await self.workflow.async_set_workflow_data(workflow_data)
             await self.workflow.async_set_workflow_status(WorkflowStatus.WAITING.value)
             # Start asynchronous task
-            self.hash_key = self.chat_id if self.chat_id else generate_uuid()
 
             execute_workflow.apply_async([unique_id, workflow_id, self.chat_id, self.user_id],
                                          queue=await self.get_execute_worker())