diff --git a/api/services/async_workflow_service.py b/api/services/async_workflow_service.py index bc73b7c8c2..94452482b3 100644 --- a/api/services/async_workflow_service.py +++ b/api/services/async_workflow_service.py @@ -155,11 +155,11 @@ class AsyncWorkflowService: task: AsyncResult[Any] | None = None if queue_name == QueuePriority.PROFESSIONAL: - task = execute_workflow_professional.delay(task_data_dict) # type: ignore + task = execute_workflow_professional.delay(task_data_dict) elif queue_name == QueuePriority.TEAM: - task = execute_workflow_team.delay(task_data_dict) # type: ignore + task = execute_workflow_team.delay(task_data_dict) else: # SANDBOX - task = execute_workflow_sandbox.delay(task_data_dict) # type: ignore + task = execute_workflow_sandbox.delay(task_data_dict) # 10. Update trigger log with task info trigger_log.status = WorkflowTriggerStatus.QUEUED @@ -170,7 +170,7 @@ class AsyncWorkflowService: return AsyncTriggerResponse( workflow_trigger_log_id=trigger_log.id, - task_id=task.id, # type: ignore + task_id=task.id, status="queued", queue=queue_name, )