server.web.models.task_instance

Task Instance Database Table.

Attributes

logger

Classes

TaskInstance

Task Instance Database Table.

Module Contents

server.web.models.task_instance.logger[source]
class server.web.models.task_instance.TaskInstance[source]

Bases: jobmon.server.web.models.Base

Task Instance Database Table.

__tablename__ = 'task_instance'[source]
to_wire_as_distributor_task_instance() → Tuple[source]

Serialize task instance object.

to_wire_as_worker_node_task_instance() → Tuple[source]

Serialize task instance object.

id: sqlalchemy.orm.Mapped[int][source]
workflow_run_id: sqlalchemy.orm.Mapped[int][source]
array_id: sqlalchemy.orm.Mapped[int][source]
task_id: sqlalchemy.orm.Mapped[int][source]
distributor_id: sqlalchemy.orm.Mapped[str][source]
task_resources_id: sqlalchemy.orm.Mapped[int][source]
array_batch_num: sqlalchemy.orm.Mapped[int][source]
array_step_id: sqlalchemy.orm.Mapped[int][source]
nodename[source]
process_group_id[source]
usage_str[source]
wallclock[source]
maxrss[source]
maxpss[source]
cpu[source]
io[source]
stdout[source]
stderr[source]
stdout_log[source]
stderr_log[source]
status: sqlalchemy.orm.Mapped[str][source]
submitted_date[source]
status_date[source]
report_by_date[source]
task[source]
errors[source]
task_resources[source]
__table_args__[source]
valid_transitions[source]
untimely_transitions[source]
error_states[source]
transition(new_state: str) → None[source]

Transition the TaskInstance status.

_validate_transition(new_state: str) → None[source]

Ensure the TaskInstance status transition is valid.

_is_timely_transition(new_state: str) → bool[source]

Check if the transition is invalid due to a race condition.