diff --git a/backend/workflow_manager/workflow_v2/workflow_helper.py b/backend/workflow_manager/workflow_v2/workflow_helper.py index f4c8a8582..5e24e3ae4 100644 --- a/backend/workflow_manager/workflow_v2/workflow_helper.py +++ b/backend/workflow_manager/workflow_v2/workflow_helper.py @@ -535,6 +535,8 @@ def execute_workflow_async( task = AsyncResultData(async_result=async_execution) celery_result = task.to_dict() task_result = celery_result.get("result") + # Fetch the object agian to get the latest status. + workflow_execution = WorkflowExecution.objects.get(id=execution_id) execution_response = ExecutionResponse( workflow_id, execution_id,