diff --git a/backend/app/utils/workforce.py b/backend/app/utils/workforce.py index 11bb0aac..535fa5e5 100644 --- a/backend/app/utils/workforce.py +++ b/backend/app/utils/workforce.py @@ -650,13 +650,14 @@ class Workforce(BaseWorkforce): })) if metrics_callbacks: - - event = TaskFailedEvent(task_id=task.id, ) + error_msg = error_message or str(task.result or "Unknown error") + event = TaskFailedEvent( + task_id=task.id, + error_message=error_msg, + ) # Add failure details if available if hasattr(task, 'assigned_worker_id'): event.worker_id = task.assigned_worker_id - event.error_message = error_message or str(task.result - or "Unknown error") event.failure_count = task.failure_count metrics_callbacks[0].log_task_failed(event)