SerializedJob

pydantic model safir.uws.SerializedJob

A single UWS job (Wobbly format).

Parameters:

data (Any)

Fields:

• creation_time (Annotated[UtcDatetime, FieldInfo(annotation=NoneType, required=True, title='Creation time', description='When the job was created', examples=['2024-10-29T23:57:55+00:00'])])

• end_time (Annotated[UtcDatetime | None, FieldInfo(annotation=NoneType, required=True, title='End time', description='When the job stopped executing (if it has)', examples=['2024-10-30T00:08:45+00:00', None])])

• errors (Annotated[list[safir.uws._models.JobError], FieldInfo(annotation=NoneType, required=True, title='Error', description='Error information if the job failed')])

• id (Annotated[str, FieldInfo(annotation=NoneType, required=True, title='Job ID', description='Unique identifier of the job', examples=['47183']), pydantic.functional_validators.BeforeValidator(func=safir.uws._models.SerializedJob.

• message_id (Annotated[str | None, FieldInfo(annotation=NoneType, required=True, title='Work queue message ID', description='Internal message identifier for the work queuing system. Only meaningful to the service that stored this ID.', examples=['e621a175-e3bf-4a61-98d7-483cb5fb9ec2'])])

• owner (Annotated[str, FieldInfo(annotation=NoneType, required=True, title='Job owner', description='Identity of the owner of the job', examples=['someuser'])])

• phase (Annotated[vo_models.uws.types.ExecutionPhase, FieldInfo(annotation=NoneType, required=True, title='Execution phase', description='Current execution phase of the job', examples=[

• quote (Annotated[UtcDatetime | None, FieldInfo(annotation=NoneType, required=True, title='Expected completion time', description='Expected completion time of the job if it were started now, or null to indicate that the expected duration is not known. If later than the destruction time, indicates that the job is not possible due to resource constraints.')])

• results (Annotated[list[safir.uws._models.JobResult], FieldInfo(annotation=NoneType, required=True, title='Job results', description='Results of the job, if it has finished')])

• service (Annotated[str, FieldInfo(annotation=NoneType, required=True, title='Service', description='Service responsible for this job', examples=['vo-cutouts'])])

• start_time (Annotated[UtcDatetime | None, FieldInfo(annotation=NoneType, required=True, title='Start time', description='When the job started executing (if it has)', examples=['2024-10-30T00:00:21+00:00', None])])

field creation_time: Annotated[TypeAliasType] [Required]

When the job was created

field end_time: Annotated[TypeAliasType | None] = None

When the job stopped executing (if it has)

field errors: Annotated[list[JobError]] = []

Error information if the job failed

field id: Annotated[str] [Required]

Unique identifier of the job

Constraints:

• func = <function SerializedJob.<lambda> at 0x7fc8f1ca3b00>

• json_schema_input_type = PydanticUndefined

field message_id: Annotated[str | None] = None

Internal message identifier for the work queuing system. Only meaningful to the service that stored this ID.

field owner: Annotated[str] [Required]

Identity of the owner of the job

field phase: Annotated[ExecutionPhase] [Required]

Current execution phase of the job

field quote: Annotated[TypeAliasType | None] = None

Expected completion time of the job if it were started now, or null to indicate that the expected duration is not known. If later than the destruction time, indicates that the job is not possible due to resource constraints.

field results: Annotated[list[JobResult]] = []

Results of the job, if it has finished

field service: Annotated[str] [Required]

Service responsible for this job

field start_time: Annotated[TypeAliasType | None] = None

When the job started executing (if it has)

to_job_description(base_url)

Convert to the Pydantic XML model used for the summary of jobs.

Parameters:

base_url (str) – Base URL for the full jobs.

Return type:

ShortJobDescription