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.
DownstreamTasksRequest	Request model for downstream tasks.
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, Any] | 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: List[Any]

class server.web.schemas.task.DownstreamTasksRequest

Bases: pydantic.BaseModel

Request model for downstream tasks.

task_ids: List[int]

dag_id: int

class server.web.schemas.task.DownstreamTasksResponse

Bases: pydantic.BaseModel

Response model for downstream tasks.

downstream_tasks: Dict[int, List[Any]]

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

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

class server.web.schemas.task.TaskDetailsResponse

Bases: pydantic.BaseModel

Response model for task details.

task_details: List[TaskDetailItem]