server.web.routes.v2.fsm.workflow_run

Routes for WorkflowRuns.

Attributes

logger

Functions

`add_workflow_run`(→ Any)	Add a workflow run to the db.
`terminate_workflow_run`(→ Any)	Terminate a workflow run and get its tasks in order.
`log_workflow_run_heartbeat`(→ Any)	Log a heartbeat for the workflow run to show that the client side is still alive.
`log_workflow_run_status_update`(→ Any)	Update the status of the workflow run.
`task_instances_status_check`(→ Any)	Sync status of given task intance IDs.
`set_status_for_triaging`(→ Any)	Two triaging related status sets.

Module Contents

server.web.routes.v2.fsm.workflow_run.logger[source]

server.web.routes.v2.fsm.workflow_run.add_workflow_run() → Any[source]: Add a workflow run to the db.

server.web.routes.v2.fsm.workflow_run.terminate_workflow_run(workflow_run_id: int) → Any[source]: Terminate a workflow run and get its tasks in order.

server.web.routes.v2.fsm.workflow_run.log_workflow_run_heartbeat(workflow_run_id: int) → Any[source]: Log a heartbeat for the workflow run to show that the client side is still alive.

server.web.routes.v2.fsm.workflow_run.log_workflow_run_status_update(workflow_run_id: int) → Any[source]: Update the status of the workflow run.

server.web.routes.v2.fsm.workflow_run.task_instances_status_check(workflow_run_id: int) → Any[source]: Sync status of given task intance IDs.

server.web.routes.v2.fsm.workflow_run.set_status_for_triaging(workflow_run_id: int) → Any[source]

Two triaging related status sets.

Query all task instances that are submitted to distributor or running which haven’t reported as alive in the allocated time, and set them for Triaging(from Running) and Kill_self(from Launched).