mypydantic.models.datapipeline

  1# Model Generated: Thu Mar  2 21:56:17 2023
  2
  3from __future__ import annotations
  4
  5from datetime import datetime
  6from typing import Dict, List, Literal, Optional, Sequence, Union
  7
  8from pydantic import Field
  9
 10from mypydantic.models.base_model import BaseModel
 11
 12
 13class ParameterValueModel(BaseModel):
 14    id: str = Field(alias="id")
 15    string_value: str = Field(alias="stringValue")
 16
 17
 18class TagModel(BaseModel):
 19    key: str = Field(alias="key")
 20    value: str = Field(alias="value")
 21
 22
 23class ResponseMetadataModel(BaseModel):
 24    request_id: str = Field(alias="RequestId")
 25    host_id: str = Field(alias="HostId")
 26    http_status_code: int = Field(alias="HTTPStatusCode")
 27    http_headers: Dict[str, str] = Field(alias="HTTPHeaders")
 28    retry_attempts: int = Field(alias="RetryAttempts")
 29
 30
 31class DeactivatePipelineInputRequestModel(BaseModel):
 32    pipeline_id: str = Field(alias="pipelineId")
 33    cancel_active: Optional[bool] = Field(default=None, alias="cancelActive")
 34
 35
 36class DeletePipelineInputRequestModel(BaseModel):
 37    pipeline_id: str = Field(alias="pipelineId")
 38
 39
 40class PaginatorConfigModel(BaseModel):
 41    max_items: Optional[int] = Field(default=None, alias="MaxItems")
 42    page_size: Optional[int] = Field(default=None, alias="PageSize")
 43    starting_token: Optional[str] = Field(default=None, alias="StartingToken")
 44
 45
 46class DescribeObjectsInputRequestModel(BaseModel):
 47    pipeline_id: str = Field(alias="pipelineId")
 48    object_ids: Sequence[str] = Field(alias="objectIds")
 49    evaluate_expressions: Optional[bool] = Field(
 50        default=None, alias="evaluateExpressions"
 51    )
 52    marker: Optional[str] = Field(default=None, alias="marker")
 53
 54
 55class DescribePipelinesInputRequestModel(BaseModel):
 56    pipeline_ids: Sequence[str] = Field(alias="pipelineIds")
 57
 58
 59class EvaluateExpressionInputRequestModel(BaseModel):
 60    pipeline_id: str = Field(alias="pipelineId")
 61    object_id: str = Field(alias="objectId")
 62    expression: str = Field(alias="expression")
 63
 64
 65class FieldModel(BaseModel):
 66    key: str = Field(alias="key")
 67    string_value: Optional[str] = Field(default=None, alias="stringValue")
 68    ref_value: Optional[str] = Field(default=None, alias="refValue")
 69
 70
 71class GetPipelineDefinitionInputRequestModel(BaseModel):
 72    pipeline_id: str = Field(alias="pipelineId")
 73    version: Optional[str] = Field(default=None, alias="version")
 74
 75
 76class InstanceIdentityModel(BaseModel):
 77    document: Optional[str] = Field(default=None, alias="document")
 78    signature: Optional[str] = Field(default=None, alias="signature")
 79
 80
 81class ListPipelinesInputRequestModel(BaseModel):
 82    marker: Optional[str] = Field(default=None, alias="marker")
 83
 84
 85class PipelineIdNameModel(BaseModel):
 86    id: Optional[str] = Field(default=None, alias="id")
 87    name: Optional[str] = Field(default=None, alias="name")
 88
 89
 90class OperatorModel(BaseModel):
 91    type: Optional[Literal["BETWEEN", "EQ", "GE", "LE", "REF_EQ"]] = Field(
 92        default=None, alias="type"
 93    )
 94    values: Optional[Sequence[str]] = Field(default=None, alias="values")
 95
 96
 97class ParameterAttributeModel(BaseModel):
 98    key: str = Field(alias="key")
 99    string_value: str = Field(alias="stringValue")
100
101
102class ValidationErrorModel(BaseModel):
103    id: Optional[str] = Field(default=None, alias="id")
104    errors: Optional[List[str]] = Field(default=None, alias="errors")
105
106
107class ValidationWarningModel(BaseModel):
108    id: Optional[str] = Field(default=None, alias="id")
109    warnings: Optional[List[str]] = Field(default=None, alias="warnings")
110
111
112class RemoveTagsInputRequestModel(BaseModel):
113    pipeline_id: str = Field(alias="pipelineId")
114    tag_keys: Sequence[str] = Field(alias="tagKeys")
115
116
117class ReportTaskRunnerHeartbeatInputRequestModel(BaseModel):
118    taskrunner_id: str = Field(alias="taskrunnerId")
119    worker_group: Optional[str] = Field(default=None, alias="workerGroup")
120    hostname: Optional[str] = Field(default=None, alias="hostname")
121
122
123class SetStatusInputRequestModel(BaseModel):
124    pipeline_id: str = Field(alias="pipelineId")
125    object_ids: Sequence[str] = Field(alias="objectIds")
126    status: str = Field(alias="status")
127
128
129class SetTaskStatusInputRequestModel(BaseModel):
130    task_id: str = Field(alias="taskId")
131    task_status: Literal["FAILED", "FALSE", "FINISHED"] = Field(alias="taskStatus")
132    error_id: Optional[str] = Field(default=None, alias="errorId")
133    error_message: Optional[str] = Field(default=None, alias="errorMessage")
134    error_stack_trace: Optional[str] = Field(default=None, alias="errorStackTrace")
135
136
137class ActivatePipelineInputRequestModel(BaseModel):
138    pipeline_id: str = Field(alias="pipelineId")
139    parameter_values: Optional[Sequence[ParameterValueModel]] = Field(
140        default=None, alias="parameterValues"
141    )
142    start_timestamp: Optional[Union[datetime, str]] = Field(
143        default=None, alias="startTimestamp"
144    )
145
146
147class AddTagsInputRequestModel(BaseModel):
148    pipeline_id: str = Field(alias="pipelineId")
149    tags: Sequence[TagModel] = Field(alias="tags")
150
151
152class CreatePipelineInputRequestModel(BaseModel):
153    name: str = Field(alias="name")
154    unique_id: str = Field(alias="uniqueId")
155    description: Optional[str] = Field(default=None, alias="description")
156    tags: Optional[Sequence[TagModel]] = Field(default=None, alias="tags")
157
158
159class CreatePipelineOutputModel(BaseModel):
160    pipeline_id: str = Field(alias="pipelineId")
161    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
162
163
164class EmptyResponseMetadataModel(BaseModel):
165    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
166
167
168class EvaluateExpressionOutputModel(BaseModel):
169    evaluated_expression: str = Field(alias="evaluatedExpression")
170    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
171
172
173class QueryObjectsOutputModel(BaseModel):
174    ids: List[str] = Field(alias="ids")
175    marker: str = Field(alias="marker")
176    has_more_results: bool = Field(alias="hasMoreResults")
177    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
178
179
180class ReportTaskProgressOutputModel(BaseModel):
181    canceled: bool = Field(alias="canceled")
182    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
183
184
185class ReportTaskRunnerHeartbeatOutputModel(BaseModel):
186    terminate: bool = Field(alias="terminate")
187    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
188
189
190class DescribeObjectsInputDescribeObjectsPaginateModel(BaseModel):
191    pipeline_id: str = Field(alias="pipelineId")
192    object_ids: Sequence[str] = Field(alias="objectIds")
193    evaluate_expressions: Optional[bool] = Field(
194        default=None, alias="evaluateExpressions"
195    )
196    pagination_config: Optional[PaginatorConfigModel] = Field(
197        default=None, alias="PaginationConfig"
198    )
199
200
201class ListPipelinesInputListPipelinesPaginateModel(BaseModel):
202    pagination_config: Optional[PaginatorConfigModel] = Field(
203        default=None, alias="PaginationConfig"
204    )
205
206
207class PipelineDescriptionModel(BaseModel):
208    pipeline_id: str = Field(alias="pipelineId")
209    name: str = Field(alias="name")
210    fields: List[FieldModel] = Field(alias="fields")
211    description: Optional[str] = Field(default=None, alias="description")
212    tags: Optional[List[TagModel]] = Field(default=None, alias="tags")
213
214
215class PipelineObjectModel(BaseModel):
216    id: str = Field(alias="id")
217    name: str = Field(alias="name")
218    fields: List[FieldModel] = Field(alias="fields")
219
220
221class ReportTaskProgressInputRequestModel(BaseModel):
222    task_id: str = Field(alias="taskId")
223    fields: Optional[Sequence[FieldModel]] = Field(default=None, alias="fields")
224
225
226class PollForTaskInputRequestModel(BaseModel):
227    worker_group: str = Field(alias="workerGroup")
228    hostname: Optional[str] = Field(default=None, alias="hostname")
229    instance_identity: Optional[InstanceIdentityModel] = Field(
230        default=None, alias="instanceIdentity"
231    )
232
233
234class ListPipelinesOutputModel(BaseModel):
235    pipeline_id_list: List[PipelineIdNameModel] = Field(alias="pipelineIdList")
236    marker: str = Field(alias="marker")
237    has_more_results: bool = Field(alias="hasMoreResults")
238    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
239
240
241class SelectorModel(BaseModel):
242    field_name: Optional[str] = Field(default=None, alias="fieldName")
243    operator: Optional[OperatorModel] = Field(default=None, alias="operator")
244
245
246class ParameterObjectModel(BaseModel):
247    id: str = Field(alias="id")
248    attributes: List[ParameterAttributeModel] = Field(alias="attributes")
249
250
251class PutPipelineDefinitionOutputModel(BaseModel):
252    validation_errors: List[ValidationErrorModel] = Field(alias="validationErrors")
253    validation_warnings: List[ValidationWarningModel] = Field(
254        alias="validationWarnings"
255    )
256    errored: bool = Field(alias="errored")
257    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
258
259
260class ValidatePipelineDefinitionOutputModel(BaseModel):
261    validation_errors: List[ValidationErrorModel] = Field(alias="validationErrors")
262    validation_warnings: List[ValidationWarningModel] = Field(
263        alias="validationWarnings"
264    )
265    errored: bool = Field(alias="errored")
266    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
267
268
269class DescribePipelinesOutputModel(BaseModel):
270    pipeline_description_list: List[PipelineDescriptionModel] = Field(
271        alias="pipelineDescriptionList"
272    )
273    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
274
275
276class DescribeObjectsOutputModel(BaseModel):
277    pipeline_objects: List[PipelineObjectModel] = Field(alias="pipelineObjects")
278    marker: str = Field(alias="marker")
279    has_more_results: bool = Field(alias="hasMoreResults")
280    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
281
282
283class TaskObjectModel(BaseModel):
284    task_id: Optional[str] = Field(default=None, alias="taskId")
285    pipeline_id: Optional[str] = Field(default=None, alias="pipelineId")
286    attempt_id: Optional[str] = Field(default=None, alias="attemptId")
287    objects: Optional[Dict[str, PipelineObjectModel]] = Field(
288        default=None, alias="objects"
289    )
290
291
292class QueryModel(BaseModel):
293    selectors: Optional[Sequence[SelectorModel]] = Field(
294        default=None, alias="selectors"
295    )
296
297
298class GetPipelineDefinitionOutputModel(BaseModel):
299    pipeline_objects: List[PipelineObjectModel] = Field(alias="pipelineObjects")
300    parameter_objects: List[ParameterObjectModel] = Field(alias="parameterObjects")
301    parameter_values: List[ParameterValueModel] = Field(alias="parameterValues")
302    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
303
304
305class PutPipelineDefinitionInputRequestModel(BaseModel):
306    pipeline_id: str = Field(alias="pipelineId")
307    pipeline_objects: Sequence[PipelineObjectModel] = Field(alias="pipelineObjects")
308    parameter_objects: Optional[Sequence[ParameterObjectModel]] = Field(
309        default=None, alias="parameterObjects"
310    )
311    parameter_values: Optional[Sequence[ParameterValueModel]] = Field(
312        default=None, alias="parameterValues"
313    )
314
315
316class ValidatePipelineDefinitionInputRequestModel(BaseModel):
317    pipeline_id: str = Field(alias="pipelineId")
318    pipeline_objects: Sequence[PipelineObjectModel] = Field(alias="pipelineObjects")
319    parameter_objects: Optional[Sequence[ParameterObjectModel]] = Field(
320        default=None, alias="parameterObjects"
321    )
322    parameter_values: Optional[Sequence[ParameterValueModel]] = Field(
323        default=None, alias="parameterValues"
324    )
325
326
327class PollForTaskOutputModel(BaseModel):
328    task_object: TaskObjectModel = Field(alias="taskObject")
329    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
330
331
332class QueryObjectsInputQueryObjectsPaginateModel(BaseModel):
333    pipeline_id: str = Field(alias="pipelineId")
334    sphere: str = Field(alias="sphere")
335    query: Optional[QueryModel] = Field(default=None, alias="query")
336    pagination_config: Optional[PaginatorConfigModel] = Field(
337        default=None, alias="PaginationConfig"
338    )
339
340
341class QueryObjectsInputRequestModel(BaseModel):
342    pipeline_id: str = Field(alias="pipelineId")
343    sphere: str = Field(alias="sphere")
344    query: Optional[QueryModel] = Field(default=None, alias="query")
345    marker: Optional[str] = Field(default=None, alias="marker")
346    limit: Optional[int] = Field(default=None, alias="limit")