From 0212f0de9f88f841447cc416254c81d99ae93cdf Mon Sep 17 00:00:00 2001 From: QuantumGhost Date: Wed, 3 Sep 2025 17:11:43 +0800 Subject: [PATCH] fix(api): fix workflow execution --- api/core/app/apps/advanced_chat/generate_task_pipeline.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/api/core/app/apps/advanced_chat/generate_task_pipeline.py b/api/core/app/apps/advanced_chat/generate_task_pipeline.py index 65a147dcdd..c50fa2ca48 100644 --- a/api/core/app/apps/advanced_chat/generate_task_pipeline.py +++ b/api/core/app/apps/advanced_chat/generate_task_pipeline.py @@ -305,7 +305,9 @@ class AdvancedChatAppGenerateTaskPipeline: err = self._base_task_pipeline._handle_error(event=event, session=session, message_id=self._message_id) yield self._base_task_pipeline._error_to_stream_response(err) - def _handle_workflow_started_event(self, **kwargs) -> Generator[StreamResponse, None, None]: + def _handle_workflow_started_event( + self, event: QueueWorkflowStartedEvent, **kwargs + ) -> Generator[StreamResponse, None, None]: """Handle workflow started events.""" with self._database_session() as session: workflow_execution = self._workflow_cycle_manager.handle_workflow_run_start()