server.web.schemas.task_template

Classes

`TaskTemplateResourceUsageRequest`
`RequestedResourcesModel`
`TaskResourceDetailItem`
`TaskResourceVizItem`
`TaskTemplateResourceUsageResponse`	Unified response model for task template resource usage.
`TaskTemplateDetailsResponse`
`TaskTemplateVersionItem`	Individual task template version item.
`TaskTemplateVersionResponse`	Response model for task template version queries.
`CoreInfoItem`	Individual core info item.
`RequestedCoresResponse`	Response model for requested cores queries.
`QueueInfoItem`	Individual queue info item.
`MostPopularQueueResponse`	Response model for most popular queue queries.
`WorkflowTaskTemplateStatusItem`	Individual workflow task template status item.
`ErrorLogItem`	Error log item - can represent individual errors or clustered errors.
`ErrorLogResponse`	Response model for error log queries.

Module Contents

class server.web.schemas.task_template.TaskTemplateResourceUsageRequest[source]

Bases: pydantic.BaseModel

task_template_version_id: int[source]

workflows: List[int] | None = None[source]

node_args: Dict[str, List[str]] | None = None[source]

ci: str | None = None[source]

viz: bool = False[source]

class server.web.schemas.task_template.RequestedResourcesModel[source]

Bases: pydantic.BaseModel

memory: float | None = None[source]

runtime: float | None = None[source]

cores: float | None = None[source]

queue: str | None = None[source]

class server.web.schemas.task_template.TaskResourceDetailItem[source]

Bases: pydantic.BaseModel

r: float | None[source]

m: int | None[source]

node_id: int[source]

task_id: int[source]

task_name: str | None = None[source]

requested_resources: str | None = None[source]

attempt_number_of_instance: int | None = None[source]

status: str | None = None[source]

task_status_date: datetime.datetime | None = None[source]

task_command: str | None = None[source]

task_num_attempts: int | None = None[source]

task_max_attempts: int | None = None[source]

model_config[source]

class server.web.schemas.task_template.TaskResourceVizItem[source]

Bases: pydantic.BaseModel

r: float | None = None[source]

m: int | None = None[source]

node_id: int[source]

task_id: int[source]

task_name: str | None = None[source]

requested_resources: str | None = None[source]

attempt_number_of_instance: int | None = None[source]

status: str | None = None[source]

task_status_date: datetime.datetime | None = None[source]

task_command: str | None = None[source]

task_num_attempts: int | None = None[source]

task_max_attempts: int | None = None[source]

class server.web.schemas.task_template.TaskTemplateResourceUsageResponse[source]

Bases: pydantic.BaseModel

Unified response model for task template resource usage.

model_config[source]

num_tasks: int | None = None[source]

min_mem: int | None = None[source]

max_mem: int | None = None[source]

mean_mem: float | None = None[source]

min_runtime: int | None = None[source]

max_runtime: int | None = None[source]

mean_runtime: float | None = None[source]

median_mem: float | None = None[source]

median_runtime: float | None = None[source]

ci_mem: List[float | None] | None = None[source]

ci_runtime: List[float | None] | None = None[source]

result_viz: List[TaskResourceVizItem] | None = None[source]

formatted_stats() → Dict[str, Any][source]: Provide formatted statistics similar to legacy client format.

class server.web.schemas.task_template.TaskTemplateDetailsResponse[source]

Bases: pydantic.BaseModel

task_template_id: int[source]

task_template_name: str[source]

task_template_version_id: int[source]

class server.web.schemas.task_template.TaskTemplateVersionItem[source]

Bases: pydantic.BaseModel

Individual task template version item.

id: int[source]

name: str[source]

class server.web.schemas.task_template.TaskTemplateVersionResponse[source]

Bases: pydantic.BaseModel

Response model for task template version queries.

task_template_version_ids: List[TaskTemplateVersionItem][source]

class server.web.schemas.task_template.CoreInfoItem[source]

Bases: pydantic.BaseModel

Individual core info item.

id: int[source]

min: int[source]

max: int[source]

avg: int[source]

class server.web.schemas.task_template.RequestedCoresResponse[source]

Bases: pydantic.BaseModel

Response model for requested cores queries.

core_info: List[CoreInfoItem][source]

class server.web.schemas.task_template.QueueInfoItem[source]

Bases: pydantic.BaseModel

Individual queue info item.

id: int[source]

queue: str[source]

queue_id: int[source]

class server.web.schemas.task_template.MostPopularQueueResponse[source]

Bases: pydantic.BaseModel

Response model for most popular queue queries.

queue_info: List[QueueInfoItem][source]

class server.web.schemas.task_template.WorkflowTaskTemplateStatusItem[source]

Bases: pydantic.BaseModel

Individual workflow task template status item.

id: int[source]

name: str[source]

tasks: int[source]

PENDING: int[source]

SCHEDULED: int[source]

RUNNING: int[source]

DONE: int[source]

FATAL: int[source]

MAXC: int | str[source]

num_attempts_min: float | None[source]

num_attempts_max: float | None[source]

num_attempts_avg: float | None[source]

task_template_version_id: int[source]

class server.web.schemas.task_template.ErrorLogItem[source]

Bases: pydantic.BaseModel

Error log item - can represent individual errors or clustered errors.

task_id: int | None = None[source]

task_instance_id: int | None = None[source]

task_instance_err_id: int | None = None[source]

error_time: datetime.datetime | None = None[source]

error: str | None = None[source]

task_instance_stderr_log: str | None = None[source]

workflow_run_id: int[source]

workflow_id: int[source]

error_score: float | None = None[source]

group_instance_count: int | None = None[source]

task_instance_ids: List[int] | None = None[source]

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

sample_error: str | None = None[source]

first_error_time: datetime.datetime | None = None[source]

model_config[source]

class server.web.schemas.task_template.ErrorLogResponse[source]

Bases: pydantic.BaseModel

Response model for error log queries.

error_logs: List[ErrorLogItem][source]

total_count: int[source]

page: int[source]

page_size: int[source]