JobCreate

pydantic model safir.uws.JobCreate

Information required to create a new UWS job (Wobbly format).

Parameters:

data (Any)

Fields:

• destruction_time (Annotated[UtcDatetime, FieldInfo(annotation=NoneType, required=True, title='Destruction time', description='At this time, the job will be aborted if it is still running, its results will be deleted, and it will either change phase to ARCHIVED or all record of the job will be discarded', examples=['2024-11-29T23:57:55+00:00'])])

• execution_duration (Annotated[SecondsTimedelta | None, FieldInfo(annotation=NoneType, required=True, title='Maximum execution duration', description='Allowed maximum execution duration. This is specified in elapsed wall clock time (not CPU time). If null, the execution time is unlimited. If the job runs for longer than this time period, it will be aborted.'), pydantic.functional_serializers.PlainSerializer(func=safir.uws._models.JobBase.

• json_parameters (Annotated[dict[str, Any], FieldInfo(annotation=NoneType, required=True, title='Job parameters', description='May be any JSON-serialized object. Stored opaquely and returned as part of the job record.', examples=[{'ids': ['data-id'], 'stencils': [{'type': 'circle', 'center': [1.1, 2.1], 'radius': 0.001}]}])])

• run_id (Annotated[str | None, FieldInfo(annotation=NoneType, required=True, title='Client-provided run ID', description='The run ID allows the client to add a unique identifier to all jobs that are part of a single operation, which may aid in tracing issues through a complex system or identifying which operation a job is part of', examples=['daily-2024-10-29'])])

field destruction_time: Annotated[TypeAliasType] [Required]

At this time, the job will be aborted if it is still running, its results will be deleted, and it will either change phase to ARCHIVED or all record of the job will be discarded

field execution_duration: Annotated[TypeAliasType | None] = None

Allowed maximum execution duration. This is specified in elapsed wall clock time (not CPU time). If null, the execution time is unlimited. If the job runs for longer than this time period, it will be aborted.

Constraints:

• func = <function JobBase.<lambda> at 0x7fc8f1ca1620>

• return_type = <class ‘int’>

• when_used = always

field json_parameters: Annotated[dict[str, Any]] [Required]

May be any JSON-serialized object. Stored opaquely and returned as part of the job record.

field run_id: Annotated[str | None] = None

The run ID allows the client to add a unique identifier to all jobs that are part of a single operation, which may aid in tracing issues through a complex system or identifying which operation a job is part of