server.web.models.workflow

Workflow Database Table.

Attributes

Classes

Workflow Database Table.

Module Contents

server.web.models.workflow.logger

class server.web.models.workflow.Workflow

Bases: jobmon.server.web.models.Base

Workflow Database Table.

to_wire_as_distributor_workflow() → tuple: Serialize workflow object.

id: sqlalchemy.orm.Mapped[int]

tool_version_id

dag_id: sqlalchemy.orm.Mapped[int]

workflow_args_hash

task_hash

description

name

workflow_args

max_concurrently_running: sqlalchemy.orm.Mapped[int]

created_date

status_date

status: sqlalchemy.orm.Mapped[str]

dag

workflow_runs

valid_transitions

untimely_transitions

transition(new_state: str) → None: Transition the state of the workflow.

link_workflow_run(workflow_run: jobmon.server.web.models.workflow_run.WorkflowRun, next_report_increment: float, dialect: str) → Tuple

Link a workflow run to this workflow.

Parameters:

workflow_run – The workflow run to link
next_report_increment – Number of seconds until next expected heartbeat
dialect – The database dialect (mysql, sqlite)

reset(current_time: datetime.datetime) → None: Set a workflow to a resumable state.

resume(reset_running_jobs: bool) → None: Resume a workflow.

property ready_to_link: bool: Is this workflow able to link a new workflow run.

property is_resumable: bool: Is this workflow resumable.