diff --git a/backend/utilities/workflow/workflow.py b/backend/utilities/workflow/workflow.py index b94e7b4..6e773ae 100644 --- a/backend/utilities/workflow/workflow.py +++ b/backend/utilities/workflow/workflow.py @@ -439,7 +439,7 @@ def report_workflow_status(self, status: int, error_task: str = ""): workflow_record.status = "FINISHED" if status == 200 else "FAILED" workflow_record.data = self.workflow_data - workflow_record.data["error_task"] = error_task + workflow_record.data["error_task"] = error_task if not error_task.endswith("batch_tasks") else "" workflow_record.end_time = datetime.now() if workflow_record.run_from == WorkflowRunRecord.RunFromTypes.CHAT: