server.web.models.task

Task Table for the Database.

Attributes

logger

Classes

Task	Task Database object.

Module Contents

server.web.models.task.logger

class server.web.models.task.Task

Bases: jobmon.server.web.models.Base

Task Database object.

__tablename__ = 'task'

to_wire_as_distributor_task() → tuple

Serialize executor task object.

to_wire_as_swarm_task() → tuple

Serialize swarm task.

id: sqlalchemy.orm.Mapped[int]

workflow_id

node_id

task_args_hash

array_id

name: sqlalchemy.orm.Mapped[str]

command: sqlalchemy.orm.Mapped[str]

task_resources_id

num_attempts: sqlalchemy.orm.Mapped[int]

max_attempts: sqlalchemy.orm.Mapped[int]

resource_scales

fallback_queues

status: sqlalchemy.orm.Mapped[str]

status_date

task_instances

task_resources

array

__table_args__

valid_transitions

reset(name: str, command: str, max_attempts: int, reset_if_running: bool) → None

Reset status and number of attempts on a Task.

transition(new_state: str) → None

Transition the Task to a new state.

transition_after_task_instance_error(job_instance_error_state: str) → None

Transition the task to an error state.

_validate_transition(new_state: str) → None

Ensure the task state transition is valid.