diff --git a/lumigator/backend/backend/api/routes/workflows.py b/lumigator/backend/backend/api/routes/workflows.py index e9c69e606..7b5397cee 100644 --- a/lumigator/backend/backend/api/routes/workflows.py +++ b/lumigator/backend/backend/api/routes/workflows.py @@ -78,5 +78,5 @@ async def delete_workflow( workflow_id: ID of the workflow to delete force: If True, force deletion even if the workflow is active or has dependencies """ - result = await service.delete_workflow(workflow_id, force=force) + result = await service.delete_workflow(workflow_id, force) return WorkflowDetailsResponse.model_validate(result.model_dump()) diff --git a/lumigator/backend/backend/services/workflows.py b/lumigator/backend/backend/services/workflows.py index ab024a64e..a0403fb01 100644 --- a/lumigator/backend/backend/services/workflows.py +++ b/lumigator/backend/backend/services/workflows.py @@ -443,7 +443,7 @@ async def create_workflow(self, request: WorkflowCreateRequest) -> WorkflowRespo async def delete_workflow(self, workflow_id: str, force: bool) -> WorkflowResponse: """Delete a workflow by ID.""" # if the workflow is running, we should throw an error - workflow = self.get_workflow(workflow_id) + workflow = await self.get_workflow(workflow_id) if workflow.status == WorkflowStatus.RUNNING and not force: raise WorkflowValidationError("Cannot delete a running workflow") return await self._tracking_client.delete_workflow(workflow_id)