Update generate_task_pipeline_fast.py

1 year ago · 5e0133ecd6
parent 608fa44695
commit 5e0133ecd6
1 changed files with 1 additions and 1 deletions
--- a/api/core/app/apps/workflow/generate_task_pipeline_fast.py
+++ b/api/core/app/apps/workflow/generate_task_pipeline_fast.py
@ -244,7 +244,7 @@ class WorkflowAppGenerateTaskPipelineFast:
                    user_id=self._user_id,
                    created_by_role=self._created_by_role,
                )
-                self._workflow_run_id = workflow_run.id
+                self._workflow_run_id = self._workflow_run.id

            elif isinstance(event, QueueWorkflowSucceededEvent):
                if not self._workflow_run_id: