Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion lumigator/backend/backend/api/routes/workflows.py
Original file line number Diff line number Diff line change
Expand Up @@ -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())
2 changes: 1 addition & 1 deletion lumigator/backend/backend/services/workflows.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down