backend - add 'paused' as a workflow run status (#3800)

This commit is contained in:
Jonathan Dobson
2025-10-23 09:58:43 -04:00
committed by GitHub
parent f66f50fc93
commit ae5a0de705
4 changed files with 9 additions and 1 deletions

View File

@@ -1262,6 +1262,7 @@ async def _cancel_workflow_run(workflow_run_id: str, organization_id: str, x_api
WorkflowRunStatus.running,
WorkflowRunStatus.created,
WorkflowRunStatus.queued,
WorkflowRunStatus.paused,
]:
continue
await app.WORKFLOW_SERVICE.mark_workflow_run_as_canceled(child_workflow_run.workflow_run_id)

View File

@@ -179,7 +179,12 @@ async def verify_workflow_run(
return None, None
if workflow_run.status not in [WorkflowRunStatus.created, WorkflowRunStatus.queued, WorkflowRunStatus.running]:
if workflow_run.status not in [
WorkflowRunStatus.created,
WorkflowRunStatus.queued,
WorkflowRunStatus.running,
WorkflowRunStatus.paused,
]:
LOG.info(
"Workflow run is not running.",
workflow_run_status=workflow_run.status,

View File

@@ -110,6 +110,7 @@ class WorkflowRunStatus(StrEnum):
canceled = "canceled"
timed_out = "timed_out"
completed = "completed"
paused = "paused"
def is_final(self) -> bool:
return self in [

View File

@@ -119,6 +119,7 @@ async def cancel_workflow_run(
WorkflowRunStatus.running,
WorkflowRunStatus.created,
WorkflowRunStatus.queued,
WorkflowRunStatus.paused,
]:
continue
await app.WORKFLOW_SERVICE.mark_workflow_run_as_canceled(child_workflow_run.workflow_run_id)