mypydantic.models.emr_containers

  1# Model Generated: Thu Mar  2 21:56:18 2023
  2
  3from __future__ import annotations
  4
  5from datetime import datetime
  6from typing import Any, Dict, List, Literal, Mapping, Optional, Sequence, Union
  7
  8from pydantic import Field
  9
 10from mypydantic.models.base_model import BaseModel
 11
 12
 13class CancelJobRunRequestModel(BaseModel):
 14    id: str = Field(alias="id")
 15    virtual_cluster_id: str = Field(alias="virtualClusterId")
 16
 17
 18class ResponseMetadataModel(BaseModel):
 19    request_id: str = Field(alias="RequestId")
 20    host_id: str = Field(alias="HostId")
 21    http_status_code: int = Field(alias="HTTPStatusCode")
 22    http_headers: Dict[str, str] = Field(alias="HTTPHeaders")
 23    retry_attempts: int = Field(alias="RetryAttempts")
 24
 25
 26class CertificateModel(BaseModel):
 27    certificate_arn: Optional[str] = Field(default=None, alias="certificateArn")
 28    certificate_data: Optional[str] = Field(default=None, alias="certificateData")
 29
 30
 31class CloudWatchMonitoringConfigurationModel(BaseModel):
 32    log_group_name: str = Field(alias="logGroupName")
 33    log_stream_name_prefix: Optional[str] = Field(
 34        default=None, alias="logStreamNamePrefix"
 35    )
 36
 37
 38class ConfigurationModel(BaseModel):
 39    classification: str = Field(alias="classification")
 40    properties: Optional[Mapping[str, str]] = Field(default=None, alias="properties")
 41    configurations: Optional[Sequence[Dict[str, Any]]] = Field(
 42        default=None, alias="configurations"
 43    )
 44
 45
 46class EksInfoModel(BaseModel):
 47    namespace: Optional[str] = Field(default=None, alias="namespace")
 48
 49
 50class DeleteJobTemplateRequestModel(BaseModel):
 51    id: str = Field(alias="id")
 52
 53
 54class DeleteManagedEndpointRequestModel(BaseModel):
 55    id: str = Field(alias="id")
 56    virtual_cluster_id: str = Field(alias="virtualClusterId")
 57
 58
 59class DeleteVirtualClusterRequestModel(BaseModel):
 60    id: str = Field(alias="id")
 61
 62
 63class DescribeJobRunRequestModel(BaseModel):
 64    id: str = Field(alias="id")
 65    virtual_cluster_id: str = Field(alias="virtualClusterId")
 66
 67
 68class DescribeJobTemplateRequestModel(BaseModel):
 69    id: str = Field(alias="id")
 70
 71
 72class DescribeManagedEndpointRequestModel(BaseModel):
 73    id: str = Field(alias="id")
 74    virtual_cluster_id: str = Field(alias="virtualClusterId")
 75
 76
 77class DescribeVirtualClusterRequestModel(BaseModel):
 78    id: str = Field(alias="id")
 79
 80
 81class SparkSqlJobDriverModel(BaseModel):
 82    entry_point: Optional[str] = Field(default=None, alias="entryPoint")
 83    spark_sql_parameters: Optional[str] = Field(
 84        default=None, alias="sparkSqlParameters"
 85    )
 86
 87
 88class SparkSubmitJobDriverModel(BaseModel):
 89    entry_point: str = Field(alias="entryPoint")
 90    entry_point_arguments: Optional[Sequence[str]] = Field(
 91        default=None, alias="entryPointArguments"
 92    )
 93    spark_submit_parameters: Optional[str] = Field(
 94        default=None, alias="sparkSubmitParameters"
 95    )
 96
 97
 98class RetryPolicyConfigurationModel(BaseModel):
 99    max_attempts: int = Field(alias="maxAttempts")
100
101
102class RetryPolicyExecutionModel(BaseModel):
103    current_attempt_count: int = Field(alias="currentAttemptCount")
104
105
106class TemplateParameterConfigurationModel(BaseModel):
107    type: Optional[Literal["NUMBER", "STRING"]] = Field(default=None, alias="type")
108    default_value: Optional[str] = Field(default=None, alias="defaultValue")
109
110
111class PaginatorConfigModel(BaseModel):
112    max_items: Optional[int] = Field(default=None, alias="MaxItems")
113    page_size: Optional[int] = Field(default=None, alias="PageSize")
114    starting_token: Optional[str] = Field(default=None, alias="StartingToken")
115
116
117class ListJobRunsRequestModel(BaseModel):
118    virtual_cluster_id: str = Field(alias="virtualClusterId")
119    created_before: Optional[Union[datetime, str]] = Field(
120        default=None, alias="createdBefore"
121    )
122    created_after: Optional[Union[datetime, str]] = Field(
123        default=None, alias="createdAfter"
124    )
125    name: Optional[str] = Field(default=None, alias="name")
126    states: Optional[
127        Sequence[
128            Literal[
129                "CANCELLED",
130                "CANCEL_PENDING",
131                "COMPLETED",
132                "FAILED",
133                "PENDING",
134                "RUNNING",
135                "SUBMITTED",
136            ]
137        ]
138    ] = Field(default=None, alias="states")
139    max_results: Optional[int] = Field(default=None, alias="maxResults")
140    next_token: Optional[str] = Field(default=None, alias="nextToken")
141
142
143class ListJobTemplatesRequestModel(BaseModel):
144    created_after: Optional[Union[datetime, str]] = Field(
145        default=None, alias="createdAfter"
146    )
147    created_before: Optional[Union[datetime, str]] = Field(
148        default=None, alias="createdBefore"
149    )
150    max_results: Optional[int] = Field(default=None, alias="maxResults")
151    next_token: Optional[str] = Field(default=None, alias="nextToken")
152
153
154class ListManagedEndpointsRequestModel(BaseModel):
155    virtual_cluster_id: str = Field(alias="virtualClusterId")
156    created_before: Optional[Union[datetime, str]] = Field(
157        default=None, alias="createdBefore"
158    )
159    created_after: Optional[Union[datetime, str]] = Field(
160        default=None, alias="createdAfter"
161    )
162    types: Optional[Sequence[str]] = Field(default=None, alias="types")
163    states: Optional[
164        Sequence[
165            Literal[
166                "ACTIVE",
167                "CREATING",
168                "TERMINATED",
169                "TERMINATED_WITH_ERRORS",
170                "TERMINATING",
171            ]
172        ]
173    ] = Field(default=None, alias="states")
174    max_results: Optional[int] = Field(default=None, alias="maxResults")
175    next_token: Optional[str] = Field(default=None, alias="nextToken")
176
177
178class ListTagsForResourceRequestModel(BaseModel):
179    resource_arn: str = Field(alias="resourceArn")
180
181
182class ListVirtualClustersRequestModel(BaseModel):
183    container_provider_id: Optional[str] = Field(
184        default=None, alias="containerProviderId"
185    )
186    container_provider_type: Optional[Literal["EKS"]] = Field(
187        default=None, alias="containerProviderType"
188    )
189    created_after: Optional[Union[datetime, str]] = Field(
190        default=None, alias="createdAfter"
191    )
192    created_before: Optional[Union[datetime, str]] = Field(
193        default=None, alias="createdBefore"
194    )
195    states: Optional[
196        Sequence[Literal["ARRESTED", "RUNNING", "TERMINATED", "TERMINATING"]]
197    ] = Field(default=None, alias="states")
198    max_results: Optional[int] = Field(default=None, alias="maxResults")
199    next_token: Optional[str] = Field(default=None, alias="nextToken")
200
201
202class S3MonitoringConfigurationModel(BaseModel):
203    log_uri: str = Field(alias="logUri")
204
205
206class ParametricCloudWatchMonitoringConfigurationModel(BaseModel):
207    log_group_name: Optional[str] = Field(default=None, alias="logGroupName")
208    log_stream_name_prefix: Optional[str] = Field(
209        default=None, alias="logStreamNamePrefix"
210    )
211
212
213class ParametricS3MonitoringConfigurationModel(BaseModel):
214    log_uri: Optional[str] = Field(default=None, alias="logUri")
215
216
217class TagResourceRequestModel(BaseModel):
218    resource_arn: str = Field(alias="resourceArn")
219    tags: Mapping[str, str] = Field(alias="tags")
220
221
222class UntagResourceRequestModel(BaseModel):
223    resource_arn: str = Field(alias="resourceArn")
224    tag_keys: Sequence[str] = Field(alias="tagKeys")
225
226
227class CancelJobRunResponseModel(BaseModel):
228    id: str = Field(alias="id")
229    virtual_cluster_id: str = Field(alias="virtualClusterId")
230    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
231
232
233class CreateJobTemplateResponseModel(BaseModel):
234    id: str = Field(alias="id")
235    name: str = Field(alias="name")
236    arn: str = Field(alias="arn")
237    created_at: datetime = Field(alias="createdAt")
238    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
239
240
241class CreateManagedEndpointResponseModel(BaseModel):
242    id: str = Field(alias="id")
243    name: str = Field(alias="name")
244    arn: str = Field(alias="arn")
245    virtual_cluster_id: str = Field(alias="virtualClusterId")
246    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
247
248
249class CreateVirtualClusterResponseModel(BaseModel):
250    id: str = Field(alias="id")
251    name: str = Field(alias="name")
252    arn: str = Field(alias="arn")
253    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
254
255
256class DeleteJobTemplateResponseModel(BaseModel):
257    id: str = Field(alias="id")
258    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
259
260
261class DeleteManagedEndpointResponseModel(BaseModel):
262    id: str = Field(alias="id")
263    virtual_cluster_id: str = Field(alias="virtualClusterId")
264    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
265
266
267class DeleteVirtualClusterResponseModel(BaseModel):
268    id: str = Field(alias="id")
269    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
270
271
272class ListTagsForResourceResponseModel(BaseModel):
273    tags: Dict[str, str] = Field(alias="tags")
274    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
275
276
277class StartJobRunResponseModel(BaseModel):
278    id: str = Field(alias="id")
279    name: str = Field(alias="name")
280    arn: str = Field(alias="arn")
281    virtual_cluster_id: str = Field(alias="virtualClusterId")
282    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
283
284
285class ContainerInfoModel(BaseModel):
286    eks_info: Optional[EksInfoModel] = Field(default=None, alias="eksInfo")
287
288
289class JobDriverModel(BaseModel):
290    spark_submit_job_driver: Optional[SparkSubmitJobDriverModel] = Field(
291        default=None, alias="sparkSubmitJobDriver"
292    )
293    spark_sql_job_driver: Optional[SparkSqlJobDriverModel] = Field(
294        default=None, alias="sparkSqlJobDriver"
295    )
296
297
298class ListJobRunsRequestListJobRunsPaginateModel(BaseModel):
299    virtual_cluster_id: str = Field(alias="virtualClusterId")
300    created_before: Optional[Union[datetime, str]] = Field(
301        default=None, alias="createdBefore"
302    )
303    created_after: Optional[Union[datetime, str]] = Field(
304        default=None, alias="createdAfter"
305    )
306    name: Optional[str] = Field(default=None, alias="name")
307    states: Optional[
308        Sequence[
309            Literal[
310                "CANCELLED",
311                "CANCEL_PENDING",
312                "COMPLETED",
313                "FAILED",
314                "PENDING",
315                "RUNNING",
316                "SUBMITTED",
317            ]
318        ]
319    ] = Field(default=None, alias="states")
320    pagination_config: Optional[PaginatorConfigModel] = Field(
321        default=None, alias="PaginationConfig"
322    )
323
324
325class ListJobTemplatesRequestListJobTemplatesPaginateModel(BaseModel):
326    created_after: Optional[Union[datetime, str]] = Field(
327        default=None, alias="createdAfter"
328    )
329    created_before: Optional[Union[datetime, str]] = Field(
330        default=None, alias="createdBefore"
331    )
332    pagination_config: Optional[PaginatorConfigModel] = Field(
333        default=None, alias="PaginationConfig"
334    )
335
336
337class ListManagedEndpointsRequestListManagedEndpointsPaginateModel(BaseModel):
338    virtual_cluster_id: str = Field(alias="virtualClusterId")
339    created_before: Optional[Union[datetime, str]] = Field(
340        default=None, alias="createdBefore"
341    )
342    created_after: Optional[Union[datetime, str]] = Field(
343        default=None, alias="createdAfter"
344    )
345    types: Optional[Sequence[str]] = Field(default=None, alias="types")
346    states: Optional[
347        Sequence[
348            Literal[
349                "ACTIVE",
350                "CREATING",
351                "TERMINATED",
352                "TERMINATED_WITH_ERRORS",
353                "TERMINATING",
354            ]
355        ]
356    ] = Field(default=None, alias="states")
357    pagination_config: Optional[PaginatorConfigModel] = Field(
358        default=None, alias="PaginationConfig"
359    )
360
361
362class ListVirtualClustersRequestListVirtualClustersPaginateModel(BaseModel):
363    container_provider_id: Optional[str] = Field(
364        default=None, alias="containerProviderId"
365    )
366    container_provider_type: Optional[Literal["EKS"]] = Field(
367        default=None, alias="containerProviderType"
368    )
369    created_after: Optional[Union[datetime, str]] = Field(
370        default=None, alias="createdAfter"
371    )
372    created_before: Optional[Union[datetime, str]] = Field(
373        default=None, alias="createdBefore"
374    )
375    states: Optional[
376        Sequence[Literal["ARRESTED", "RUNNING", "TERMINATED", "TERMINATING"]]
377    ] = Field(default=None, alias="states")
378    pagination_config: Optional[PaginatorConfigModel] = Field(
379        default=None, alias="PaginationConfig"
380    )
381
382
383class MonitoringConfigurationModel(BaseModel):
384    persistent_app_ui: Optional[Literal["DISABLED", "ENABLED"]] = Field(
385        default=None, alias="persistentAppUI"
386    )
387    cloud_watch_monitoring_configuration: Optional[
388        CloudWatchMonitoringConfigurationModel
389    ] = Field(default=None, alias="cloudWatchMonitoringConfiguration")
390    s3_monitoring_configuration: Optional[S3MonitoringConfigurationModel] = Field(
391        default=None, alias="s3MonitoringConfiguration"
392    )
393
394
395class ParametricMonitoringConfigurationModel(BaseModel):
396    persistent_app_ui: Optional[str] = Field(default=None, alias="persistentAppUI")
397    cloud_watch_monitoring_configuration: Optional[
398        ParametricCloudWatchMonitoringConfigurationModel
399    ] = Field(default=None, alias="cloudWatchMonitoringConfiguration")
400    s3_monitoring_configuration: Optional[
401        ParametricS3MonitoringConfigurationModel
402    ] = Field(default=None, alias="s3MonitoringConfiguration")
403
404
405class ContainerProviderModel(BaseModel):
406    type: Literal["EKS"] = Field(alias="type")
407    id: str = Field(alias="id")
408    info: Optional[ContainerInfoModel] = Field(default=None, alias="info")
409
410
411class ConfigurationOverridesModel(BaseModel):
412    application_configuration: Optional[Sequence[ConfigurationModel]] = Field(
413        default=None, alias="applicationConfiguration"
414    )
415    monitoring_configuration: Optional[MonitoringConfigurationModel] = Field(
416        default=None, alias="monitoringConfiguration"
417    )
418
419
420class ParametricConfigurationOverridesModel(BaseModel):
421    application_configuration: Optional[Sequence[ConfigurationModel]] = Field(
422        default=None, alias="applicationConfiguration"
423    )
424    monitoring_configuration: Optional[ParametricMonitoringConfigurationModel] = Field(
425        default=None, alias="monitoringConfiguration"
426    )
427
428
429class CreateVirtualClusterRequestModel(BaseModel):
430    name: str = Field(alias="name")
431    container_provider: ContainerProviderModel = Field(alias="containerProvider")
432    client_token: str = Field(alias="clientToken")
433    tags: Optional[Mapping[str, str]] = Field(default=None, alias="tags")
434
435
436class VirtualClusterModel(BaseModel):
437    id: Optional[str] = Field(default=None, alias="id")
438    name: Optional[str] = Field(default=None, alias="name")
439    arn: Optional[str] = Field(default=None, alias="arn")
440    state: Optional[
441        Literal["ARRESTED", "RUNNING", "TERMINATED", "TERMINATING"]
442    ] = Field(default=None, alias="state")
443    container_provider: Optional[ContainerProviderModel] = Field(
444        default=None, alias="containerProvider"
445    )
446    created_at: Optional[datetime] = Field(default=None, alias="createdAt")
447    tags: Optional[Dict[str, str]] = Field(default=None, alias="tags")
448
449
450class CreateManagedEndpointRequestModel(BaseModel):
451    name: str = Field(alias="name")
452    virtual_cluster_id: str = Field(alias="virtualClusterId")
453    type: str = Field(alias="type")
454    release_label: str = Field(alias="releaseLabel")
455    execution_role_arn: str = Field(alias="executionRoleArn")
456    client_token: str = Field(alias="clientToken")
457    certificate_arn: Optional[str] = Field(default=None, alias="certificateArn")
458    configuration_overrides: Optional[ConfigurationOverridesModel] = Field(
459        default=None, alias="configurationOverrides"
460    )
461    tags: Optional[Mapping[str, str]] = Field(default=None, alias="tags")
462
463
464class EndpointModel(BaseModel):
465    id: Optional[str] = Field(default=None, alias="id")
466    name: Optional[str] = Field(default=None, alias="name")
467    arn: Optional[str] = Field(default=None, alias="arn")
468    virtual_cluster_id: Optional[str] = Field(default=None, alias="virtualClusterId")
469    type: Optional[str] = Field(default=None, alias="type")
470    state: Optional[
471        Literal[
472            "ACTIVE", "CREATING", "TERMINATED", "TERMINATED_WITH_ERRORS", "TERMINATING"
473        ]
474    ] = Field(default=None, alias="state")
475    release_label: Optional[str] = Field(default=None, alias="releaseLabel")
476    execution_role_arn: Optional[str] = Field(default=None, alias="executionRoleArn")
477    certificate_arn: Optional[str] = Field(default=None, alias="certificateArn")
478    certificate_authority: Optional[CertificateModel] = Field(
479        default=None, alias="certificateAuthority"
480    )
481    configuration_overrides: Optional[ConfigurationOverridesModel] = Field(
482        default=None, alias="configurationOverrides"
483    )
484    server_url: Optional[str] = Field(default=None, alias="serverUrl")
485    created_at: Optional[datetime] = Field(default=None, alias="createdAt")
486    security_group: Optional[str] = Field(default=None, alias="securityGroup")
487    subnet_ids: Optional[List[str]] = Field(default=None, alias="subnetIds")
488    state_details: Optional[str] = Field(default=None, alias="stateDetails")
489    failure_reason: Optional[
490        Literal[
491            "CLUSTER_UNAVAILABLE", "INTERNAL_ERROR", "USER_ERROR", "VALIDATION_ERROR"
492        ]
493    ] = Field(default=None, alias="failureReason")
494    tags: Optional[Dict[str, str]] = Field(default=None, alias="tags")
495
496
497class JobRunModel(BaseModel):
498    id: Optional[str] = Field(default=None, alias="id")
499    name: Optional[str] = Field(default=None, alias="name")
500    virtual_cluster_id: Optional[str] = Field(default=None, alias="virtualClusterId")
501    arn: Optional[str] = Field(default=None, alias="arn")
502    state: Optional[
503        Literal[
504            "CANCELLED",
505            "CANCEL_PENDING",
506            "COMPLETED",
507            "FAILED",
508            "PENDING",
509            "RUNNING",
510            "SUBMITTED",
511        ]
512    ] = Field(default=None, alias="state")
513    client_token: Optional[str] = Field(default=None, alias="clientToken")
514    execution_role_arn: Optional[str] = Field(default=None, alias="executionRoleArn")
515    release_label: Optional[str] = Field(default=None, alias="releaseLabel")
516    configuration_overrides: Optional[ConfigurationOverridesModel] = Field(
517        default=None, alias="configurationOverrides"
518    )
519    job_driver: Optional[JobDriverModel] = Field(default=None, alias="jobDriver")
520    created_at: Optional[datetime] = Field(default=None, alias="createdAt")
521    created_by: Optional[str] = Field(default=None, alias="createdBy")
522    finished_at: Optional[datetime] = Field(default=None, alias="finishedAt")
523    state_details: Optional[str] = Field(default=None, alias="stateDetails")
524    failure_reason: Optional[
525        Literal[
526            "CLUSTER_UNAVAILABLE", "INTERNAL_ERROR", "USER_ERROR", "VALIDATION_ERROR"
527        ]
528    ] = Field(default=None, alias="failureReason")
529    tags: Optional[Dict[str, str]] = Field(default=None, alias="tags")
530    retry_policy_configuration: Optional[RetryPolicyConfigurationModel] = Field(
531        default=None, alias="retryPolicyConfiguration"
532    )
533    retry_policy_execution: Optional[RetryPolicyExecutionModel] = Field(
534        default=None, alias="retryPolicyExecution"
535    )
536
537
538class StartJobRunRequestModel(BaseModel):
539    virtual_cluster_id: str = Field(alias="virtualClusterId")
540    client_token: str = Field(alias="clientToken")
541    name: Optional[str] = Field(default=None, alias="name")
542    execution_role_arn: Optional[str] = Field(default=None, alias="executionRoleArn")
543    release_label: Optional[str] = Field(default=None, alias="releaseLabel")
544    job_driver: Optional[JobDriverModel] = Field(default=None, alias="jobDriver")
545    configuration_overrides: Optional[ConfigurationOverridesModel] = Field(
546        default=None, alias="configurationOverrides"
547    )
548    tags: Optional[Mapping[str, str]] = Field(default=None, alias="tags")
549    job_template_id: Optional[str] = Field(default=None, alias="jobTemplateId")
550    job_template_parameters: Optional[Mapping[str, str]] = Field(
551        default=None, alias="jobTemplateParameters"
552    )
553    retry_policy_configuration: Optional[RetryPolicyConfigurationModel] = Field(
554        default=None, alias="retryPolicyConfiguration"
555    )
556
557
558class JobTemplateDataModel(BaseModel):
559    execution_role_arn: str = Field(alias="executionRoleArn")
560    release_label: str = Field(alias="releaseLabel")
561    job_driver: JobDriverModel = Field(alias="jobDriver")
562    configuration_overrides: Optional[ParametricConfigurationOverridesModel] = Field(
563        default=None, alias="configurationOverrides"
564    )
565    parameter_configuration: Optional[
566        Mapping[str, TemplateParameterConfigurationModel]
567    ] = Field(default=None, alias="parameterConfiguration")
568    job_tags: Optional[Mapping[str, str]] = Field(default=None, alias="jobTags")
569
570
571class DescribeVirtualClusterResponseModel(BaseModel):
572    virtual_cluster: VirtualClusterModel = Field(alias="virtualCluster")
573    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
574
575
576class ListVirtualClustersResponseModel(BaseModel):
577    virtual_clusters: List[VirtualClusterModel] = Field(alias="virtualClusters")
578    next_token: str = Field(alias="nextToken")
579    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
580
581
582class DescribeManagedEndpointResponseModel(BaseModel):
583    endpoint: EndpointModel = Field(alias="endpoint")
584    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
585
586
587class ListManagedEndpointsResponseModel(BaseModel):
588    endpoints: List[EndpointModel] = Field(alias="endpoints")
589    next_token: str = Field(alias="nextToken")
590    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
591
592
593class DescribeJobRunResponseModel(BaseModel):
594    job_run: JobRunModel = Field(alias="jobRun")
595    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
596
597
598class ListJobRunsResponseModel(BaseModel):
599    job_runs: List[JobRunModel] = Field(alias="jobRuns")
600    next_token: str = Field(alias="nextToken")
601    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
602
603
604class CreateJobTemplateRequestModel(BaseModel):
605    name: str = Field(alias="name")
606    client_token: str = Field(alias="clientToken")
607    job_template_data: JobTemplateDataModel = Field(alias="jobTemplateData")
608    tags: Optional[Mapping[str, str]] = Field(default=None, alias="tags")
609    kms_key_arn: Optional[str] = Field(default=None, alias="kmsKeyArn")
610
611
612class JobTemplateModel(BaseModel):
613    job_template_data: JobTemplateDataModel = Field(alias="jobTemplateData")
614    name: Optional[str] = Field(default=None, alias="name")
615    id: Optional[str] = Field(default=None, alias="id")
616    arn: Optional[str] = Field(default=None, alias="arn")
617    created_at: Optional[datetime] = Field(default=None, alias="createdAt")
618    created_by: Optional[str] = Field(default=None, alias="createdBy")
619    tags: Optional[Dict[str, str]] = Field(default=None, alias="tags")
620    kms_key_arn: Optional[str] = Field(default=None, alias="kmsKeyArn")
621    decryption_error: Optional[str] = Field(default=None, alias="decryptionError")
622
623
624class DescribeJobTemplateResponseModel(BaseModel):
625    job_template: JobTemplateModel = Field(alias="jobTemplate")
626    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
627
628
629class ListJobTemplatesResponseModel(BaseModel):
630    templates: List[JobTemplateModel] = Field(alias="templates")
631    next_token: str = Field(alias="nextToken")
632    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")