server.web.schemas.task

Classes

TaskStatusRequest	Request model for task status queries.
TaskStatusItem	Individual task status item.
TaskStatusResponse	Response model for task status.
TaskSubdagRequest	Request model for task subdag.
TaskSubdagResponse	Response model for task subdag.
TaskDependencyItem	Individual task dependency item.
TaskDependenciesResponse	Response model for task dependencies.
TasksRecursiveRequest	Request model for recursive tasks.
TasksRecursiveResponse	Response model for recursive tasks.
TaskResourceUsageResponse	Response model for task resource usage.
DownstreamTasksResponse	Response model for downstream tasks.
TaskInstanceDetailItem	Individual task instance detail item.
TaskInstanceDetailsResponse	Response model for task instance details.
TaskDetailItem	Individual task detail item.
TaskDetailsResponse	Response model for task details.

Module Contents

class server.web.schemas.task.TaskStatusRequest

Bases: pydantic.BaseModel

Request model for task status queries.

task_ids: int | List[int] | None = None

status: str | List[str] | None = None

class server.web.schemas.task.TaskStatusItem

Bases: pydantic.BaseModel

Individual task status item.

TASK_ID: int

task_status: str

TASK_INSTANCE_ID: int

DISTRIBUTOR_ID: str | None

STATUS: str

RESOURCE_USAGE: str | None

STDOUT: str | None

STDERR: str | None

ERROR_TRACE: str | None

class server.web.schemas.task.TaskStatusResponse

Bases: pydantic.BaseModel

Response model for task status.

task_instance_status: str

class server.web.schemas.task.TaskSubdagRequest

Bases: pydantic.BaseModel

Request model for task subdag.

task_ids: List[int]

task_status: List[str] | None = []

class server.web.schemas.task.TaskSubdagResponse

Bases: pydantic.BaseModel

Response model for task subdag.

workflow_id: int | None

sub_task: Dict[int, List[str]] | None

class server.web.schemas.task.TaskDependencyItem

Bases: pydantic.BaseModel

Individual task dependency item.

id: int

status: str

name: str

class server.web.schemas.task.TaskDependenciesResponse

Bases: pydantic.BaseModel

Response model for task dependencies.

up: List[List[TaskDependencyItem]]

down: List[List[TaskDependencyItem]]

class server.web.schemas.task.TasksRecursiveRequest

Bases: pydantic.BaseModel

Request model for recursive tasks.

task_ids: List[int]

class server.web.schemas.task.TasksRecursiveResponse

Bases: pydantic.BaseModel

Response model for recursive tasks.

task_ids: List[int]

class server.web.schemas.task.TaskResourceUsageResponse

Bases: pydantic.BaseModel

Response model for task resource usage.

resource_usage is a 4-element list from SerializeTaskResourceUsage.to_wire(): [num_attempts, nodename, runtime, memory]

resource_usage: List[int | str | None]

class server.web.schemas.task.DownstreamTasksResponse

Bases: pydantic.BaseModel

Response model for downstream tasks.

Each value is [node_id, downstream_node_ids] where downstream_node_ids is a list of ints (new clients) or a JSON string (legacy clients) or None.

downstream_tasks: Dict[int, List[int | List[int] | str | None]]

class server.web.schemas.task.TaskInstanceDetailItem

Bases: pydantic.BaseModel

Individual task instance detail item.

ti_id: int

ti_status: str

ti_stdout: str | None

ti_stderr: str | None

ti_stdout_log: str | None

ti_stderr_log: str | None

ti_distributor_id: str | None

ti_nodename: str | None

ti_error_log_description: str | None

ti_wallclock: float | None

ti_maxrss: float | None

ti_resources: str | None

ti_submit_date: str | None

ti_status_date: str | None

ti_queue_name: str | None

ti_cpu: str | None

ti_io: str | None

ti_workflow_run_id: int | None = None

class server.web.schemas.task.TaskInstanceDetailsResponse

Bases: pydantic.BaseModel

Response model for task instance details.

taskinstances: List[TaskInstanceDetailItem]

class server.web.schemas.task.TaskDetailItem

Bases: pydantic.BaseModel

Individual task detail item.

task_status: str

workflow_id: int

task_name: str

task_command: str

task_status_date: str

task_template_id: int

num_attempts: int

max_attempts: int

class server.web.schemas.task.TaskDetailsResponse

Bases: pydantic.BaseModel

Response model for task details.

task_details: List[TaskDetailItem]