server.web.models.task_instance

Task Instance Database Table.

Attributes

Classes

Task Instance Database Table.

Module Contents

server.web.models.task_instance.logger

class server.web.models.task_instance.TaskInstance

Bases: jobmon.server.web.models.Base

Task Instance Database Table.

to_wire_as_distributor_task_instance() → Tuple: Serialize task instance object.

to_wire_as_worker_node_task_instance() → Tuple: Serialize task instance object.

id: sqlalchemy.orm.Mapped[int]

workflow_run_id: sqlalchemy.orm.Mapped[int]

array_id: sqlalchemy.orm.Mapped[int]

task_id: sqlalchemy.orm.Mapped[int]

distributor_id: sqlalchemy.orm.Mapped[str]

task_resources_id: sqlalchemy.orm.Mapped[int]

array_batch_num: sqlalchemy.orm.Mapped[int]

array_step_id: sqlalchemy.orm.Mapped[int]

nodename

process_group_id

usage_str

wallclock

maxrss

maxpss

cpu

io

stdout

stderr

stdout_log

stderr_log

status: sqlalchemy.orm.Mapped[str]

submitted_date

status_date

report_by_date

task

errors

task_resources

valid_transitions

untimely_transitions

error_states

transition(new_state: str) → None: Transition the TaskInstance status.