server.web.models.workflow

Workflow Database Table.

Attributes

Classes

Workflow Database Table.

Module Contents

server.web.models.workflow.logger[source]

class server.web.models.workflow.Workflow[source]

Bases: jobmon.server.web.models.Base

Workflow Database Table.

__tablename__ = 'workflow'[source]

to_wire_as_distributor_workflow() → tuple[source]: Serialize workflow object.

id: sqlalchemy.orm.Mapped[int][source]

tool_version_id[source]

dag_id: sqlalchemy.orm.Mapped[int][source]

workflow_args_hash[source]

task_hash[source]

description[source]

name[source]

workflow_args[source]

max_concurrently_running: sqlalchemy.orm.Mapped[int][source]

created_date[source]

status_date[source]

status: sqlalchemy.orm.Mapped[str][source]

dag[source]

workflow_runs[source]

valid_transitions[source]

untimely_transitions[source]

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

_validate_transition(new_state: str) → None[source]: Ensure the Job state transition is valid.

_is_timely_transition(new_state: str) → bool[source]: Check if the transition is invalid due to a race condition.

link_workflow_run(workflow_run: jobmon.server.web.models.workflow_run.WorkflowRun, next_report_increment: float) → Tuple[source]: Link a workflow run to this workflow.

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

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

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

property is_resumable: bool[source]: Is this workflow resumable.