server.web.models.task

Task Table for the Database.

Attributes

Classes

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.

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

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.