mypydantic.models.emr

   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 ResponseMetadataModel(BaseModel):
  14    request_id: str = Field(alias="RequestId")
  15    host_id: str = Field(alias="HostId")
  16    http_status_code: int = Field(alias="HTTPStatusCode")
  17    http_headers: Dict[str, str] = Field(alias="HTTPHeaders")
  18    retry_attempts: int = Field(alias="RetryAttempts")
  19
  20
  21class TagModel(BaseModel):
  22    key: Optional[str] = Field(default=None, alias="Key")
  23    value: Optional[str] = Field(default=None, alias="Value")
  24
  25
  26class ApplicationModel(BaseModel):
  27    name: Optional[str] = Field(default=None, alias="Name")
  28    version: Optional[str] = Field(default=None, alias="Version")
  29    args: Optional[List[str]] = Field(default=None, alias="Args")
  30    additional_info: Optional[Dict[str, str]] = Field(
  31        default=None, alias="AdditionalInfo"
  32    )
  33
  34
  35class ScalingConstraintsModel(BaseModel):
  36    min_capacity: int = Field(alias="MinCapacity")
  37    max_capacity: int = Field(alias="MaxCapacity")
  38
  39
  40class AutoScalingPolicyStateChangeReasonModel(BaseModel):
  41    code: Optional[
  42        Literal["CLEANUP_FAILURE", "PROVISION_FAILURE", "USER_REQUEST"]
  43    ] = Field(default=None, alias="Code")
  44    message: Optional[str] = Field(default=None, alias="Message")
  45
  46
  47class AutoTerminationPolicyModel(BaseModel):
  48    idle_timeout: Optional[int] = Field(default=None, alias="IdleTimeout")
  49
  50
  51class BlockPublicAccessConfigurationMetadataModel(BaseModel):
  52    creation_date_time: datetime = Field(alias="CreationDateTime")
  53    created_by_arn: str = Field(alias="CreatedByArn")
  54
  55
  56class PortRangeModel(BaseModel):
  57    min_range: int = Field(alias="MinRange")
  58    max_range: Optional[int] = Field(default=None, alias="MaxRange")
  59
  60
  61class ScriptBootstrapActionConfigModel(BaseModel):
  62    path: str = Field(alias="Path")
  63    args: Optional[List[str]] = Field(default=None, alias="Args")
  64
  65
  66class CancelStepsInfoModel(BaseModel):
  67    step_id: Optional[str] = Field(default=None, alias="StepId")
  68    status: Optional[Literal["FAILED", "SUBMITTED"]] = Field(
  69        default=None, alias="Status"
  70    )
  71    reason: Optional[str] = Field(default=None, alias="Reason")
  72
  73
  74class CancelStepsInputRequestModel(BaseModel):
  75    cluster_id: str = Field(alias="ClusterId")
  76    step_ids: Sequence[str] = Field(alias="StepIds")
  77    step_cancellation_option: Optional[
  78        Literal["SEND_INTERRUPT", "TERMINATE_PROCESS"]
  79    ] = Field(default=None, alias="StepCancellationOption")
  80
  81
  82class MetricDimensionModel(BaseModel):
  83    key: Optional[str] = Field(default=None, alias="Key")
  84    value: Optional[str] = Field(default=None, alias="Value")
  85
  86
  87class ClusterStateChangeReasonModel(BaseModel):
  88    code: Optional[
  89        Literal[
  90            "ALL_STEPS_COMPLETED",
  91            "BOOTSTRAP_FAILURE",
  92            "INSTANCE_FAILURE",
  93            "INSTANCE_FLEET_TIMEOUT",
  94            "INTERNAL_ERROR",
  95            "STEP_FAILURE",
  96            "USER_REQUEST",
  97            "VALIDATION_ERROR",
  98        ]
  99    ] = Field(default=None, alias="Code")
 100    message: Optional[str] = Field(default=None, alias="Message")
 101
 102
 103class ClusterTimelineModel(BaseModel):
 104    creation_date_time: Optional[datetime] = Field(
 105        default=None, alias="CreationDateTime"
 106    )
 107    ready_date_time: Optional[datetime] = Field(default=None, alias="ReadyDateTime")
 108    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 109
 110
 111class Ec2InstanceAttributesModel(BaseModel):
 112    ec2_key_name: Optional[str] = Field(default=None, alias="Ec2KeyName")
 113    ec2_subnet_id: Optional[str] = Field(default=None, alias="Ec2SubnetId")
 114    requested_ec2_subnet_ids: Optional[List[str]] = Field(
 115        default=None, alias="RequestedEc2SubnetIds"
 116    )
 117    ec2_availability_zone: Optional[str] = Field(
 118        default=None, alias="Ec2AvailabilityZone"
 119    )
 120    requested_ec2_availability_zones: Optional[List[str]] = Field(
 121        default=None, alias="RequestedEc2AvailabilityZones"
 122    )
 123    iam_instance_profile: Optional[str] = Field(
 124        default=None, alias="IamInstanceProfile"
 125    )
 126    emr_managed_master_security_group: Optional[str] = Field(
 127        default=None, alias="EmrManagedMasterSecurityGroup"
 128    )
 129    emr_managed_slave_security_group: Optional[str] = Field(
 130        default=None, alias="EmrManagedSlaveSecurityGroup"
 131    )
 132    service_access_security_group: Optional[str] = Field(
 133        default=None, alias="ServiceAccessSecurityGroup"
 134    )
 135    additional_master_security_groups: Optional[List[str]] = Field(
 136        default=None, alias="AdditionalMasterSecurityGroups"
 137    )
 138    additional_slave_security_groups: Optional[List[str]] = Field(
 139        default=None, alias="AdditionalSlaveSecurityGroups"
 140    )
 141
 142
 143class KerberosAttributesModel(BaseModel):
 144    realm: str = Field(alias="Realm")
 145    kdc_admin_password: str = Field(alias="KdcAdminPassword")
 146    cross_realm_trust_principal_password: Optional[str] = Field(
 147        default=None, alias="CrossRealmTrustPrincipalPassword"
 148    )
 149    addomain_join_user: Optional[str] = Field(default=None, alias="ADDomainJoinUser")
 150    addomain_join_password: Optional[str] = Field(
 151        default=None, alias="ADDomainJoinPassword"
 152    )
 153
 154
 155class PlacementGroupConfigModel(BaseModel):
 156    instance_role: Literal["CORE", "MASTER", "TASK"] = Field(alias="InstanceRole")
 157    placement_strategy: Optional[
 158        Literal["CLUSTER", "NONE", "PARTITION", "SPREAD"]
 159    ] = Field(default=None, alias="PlacementStrategy")
 160
 161
 162class CommandModel(BaseModel):
 163    name: Optional[str] = Field(default=None, alias="Name")
 164    script_path: Optional[str] = Field(default=None, alias="ScriptPath")
 165    args: Optional[List[str]] = Field(default=None, alias="Args")
 166
 167
 168class ComputeLimitsModel(BaseModel):
 169    unit_type: Literal["InstanceFleetUnits", "Instances", "VCPU"] = Field(
 170        alias="UnitType"
 171    )
 172    minimum_capacity_units: int = Field(alias="MinimumCapacityUnits")
 173    maximum_capacity_units: int = Field(alias="MaximumCapacityUnits")
 174    maximum_on_demand_capacity_units: Optional[int] = Field(
 175        default=None, alias="MaximumOnDemandCapacityUnits"
 176    )
 177    maximum_core_capacity_units: Optional[int] = Field(
 178        default=None, alias="MaximumCoreCapacityUnits"
 179    )
 180
 181
 182class ConfigurationModel(BaseModel):
 183    classification: Optional[str] = Field(default=None, alias="Classification")
 184    configurations: Optional[Sequence[Dict[str, Any]]] = Field(
 185        default=None, alias="Configurations"
 186    )
 187    properties: Optional[Mapping[str, str]] = Field(default=None, alias="Properties")
 188
 189
 190class CreateSecurityConfigurationInputRequestModel(BaseModel):
 191    name: str = Field(alias="Name")
 192    security_configuration: str = Field(alias="SecurityConfiguration")
 193
 194
 195class CreateStudioSessionMappingInputRequestModel(BaseModel):
 196    studio_id: str = Field(alias="StudioId")
 197    identity_type: Literal["GROUP", "USER"] = Field(alias="IdentityType")
 198    session_policy_arn: str = Field(alias="SessionPolicyArn")
 199    identity_id: Optional[str] = Field(default=None, alias="IdentityId")
 200    identity_name: Optional[str] = Field(default=None, alias="IdentityName")
 201
 202
 203class UsernamePasswordModel(BaseModel):
 204    username: Optional[str] = Field(default=None, alias="Username")
 205    password: Optional[str] = Field(default=None, alias="Password")
 206
 207
 208class DeleteSecurityConfigurationInputRequestModel(BaseModel):
 209    name: str = Field(alias="Name")
 210
 211
 212class DeleteStudioInputRequestModel(BaseModel):
 213    studio_id: str = Field(alias="StudioId")
 214
 215
 216class DeleteStudioSessionMappingInputRequestModel(BaseModel):
 217    studio_id: str = Field(alias="StudioId")
 218    identity_type: Literal["GROUP", "USER"] = Field(alias="IdentityType")
 219    identity_id: Optional[str] = Field(default=None, alias="IdentityId")
 220    identity_name: Optional[str] = Field(default=None, alias="IdentityName")
 221
 222
 223class WaiterConfigModel(BaseModel):
 224    delay: Optional[int] = Field(default=None, alias="Delay")
 225    max_attempts: Optional[int] = Field(default=None, alias="MaxAttempts")
 226
 227
 228class DescribeClusterInputRequestModel(BaseModel):
 229    cluster_id: str = Field(alias="ClusterId")
 230
 231
 232class DescribeJobFlowsInputRequestModel(BaseModel):
 233    created_after: Optional[Union[datetime, str]] = Field(
 234        default=None, alias="CreatedAfter"
 235    )
 236    created_before: Optional[Union[datetime, str]] = Field(
 237        default=None, alias="CreatedBefore"
 238    )
 239    job_flow_ids: Optional[Sequence[str]] = Field(default=None, alias="JobFlowIds")
 240    job_flow_states: Optional[
 241        Sequence[
 242            Literal[
 243                "BOOTSTRAPPING",
 244                "COMPLETED",
 245                "FAILED",
 246                "RUNNING",
 247                "SHUTTING_DOWN",
 248                "STARTING",
 249                "TERMINATED",
 250                "WAITING",
 251            ]
 252        ]
 253    ] = Field(default=None, alias="JobFlowStates")
 254
 255
 256class DescribeNotebookExecutionInputRequestModel(BaseModel):
 257    notebook_execution_id: str = Field(alias="NotebookExecutionId")
 258
 259
 260class DescribeReleaseLabelInputRequestModel(BaseModel):
 261    release_label: Optional[str] = Field(default=None, alias="ReleaseLabel")
 262    next_token: Optional[str] = Field(default=None, alias="NextToken")
 263    max_results: Optional[int] = Field(default=None, alias="MaxResults")
 264
 265
 266class OSReleaseModel(BaseModel):
 267    label: Optional[str] = Field(default=None, alias="Label")
 268
 269
 270class SimplifiedApplicationModel(BaseModel):
 271    name: Optional[str] = Field(default=None, alias="Name")
 272    version: Optional[str] = Field(default=None, alias="Version")
 273
 274
 275class DescribeSecurityConfigurationInputRequestModel(BaseModel):
 276    name: str = Field(alias="Name")
 277
 278
 279class DescribeStepInputRequestModel(BaseModel):
 280    cluster_id: str = Field(alias="ClusterId")
 281    step_id: str = Field(alias="StepId")
 282
 283
 284class DescribeStudioInputRequestModel(BaseModel):
 285    studio_id: str = Field(alias="StudioId")
 286
 287
 288class VolumeSpecificationModel(BaseModel):
 289    volume_type: str = Field(alias="VolumeType")
 290    size_in_gb: int = Field(alias="SizeInGB")
 291    iops: Optional[int] = Field(default=None, alias="Iops")
 292    throughput: Optional[int] = Field(default=None, alias="Throughput")
 293
 294
 295class EbsVolumeModel(BaseModel):
 296    device: Optional[str] = Field(default=None, alias="Device")
 297    volume_id: Optional[str] = Field(default=None, alias="VolumeId")
 298
 299
 300class ExecutionEngineConfigModel(BaseModel):
 301    id: str = Field(alias="Id")
 302    type: Optional[Literal["EMR"]] = Field(default=None, alias="Type")
 303    master_instance_security_group_id: Optional[str] = Field(
 304        default=None, alias="MasterInstanceSecurityGroupId"
 305    )
 306
 307
 308class FailureDetailsModel(BaseModel):
 309    reason: Optional[str] = Field(default=None, alias="Reason")
 310    message: Optional[str] = Field(default=None, alias="Message")
 311    log_file: Optional[str] = Field(default=None, alias="LogFile")
 312
 313
 314class GetAutoTerminationPolicyInputRequestModel(BaseModel):
 315    cluster_id: str = Field(alias="ClusterId")
 316
 317
 318class GetClusterSessionCredentialsInputRequestModel(BaseModel):
 319    cluster_id: str = Field(alias="ClusterId")
 320    execution_role_arn: str = Field(alias="ExecutionRoleArn")
 321
 322
 323class GetManagedScalingPolicyInputRequestModel(BaseModel):
 324    cluster_id: str = Field(alias="ClusterId")
 325
 326
 327class GetStudioSessionMappingInputRequestModel(BaseModel):
 328    studio_id: str = Field(alias="StudioId")
 329    identity_type: Literal["GROUP", "USER"] = Field(alias="IdentityType")
 330    identity_id: Optional[str] = Field(default=None, alias="IdentityId")
 331    identity_name: Optional[str] = Field(default=None, alias="IdentityName")
 332
 333
 334class SessionMappingDetailModel(BaseModel):
 335    studio_id: Optional[str] = Field(default=None, alias="StudioId")
 336    identity_id: Optional[str] = Field(default=None, alias="IdentityId")
 337    identity_name: Optional[str] = Field(default=None, alias="IdentityName")
 338    identity_type: Optional[Literal["GROUP", "USER"]] = Field(
 339        default=None, alias="IdentityType"
 340    )
 341    session_policy_arn: Optional[str] = Field(default=None, alias="SessionPolicyArn")
 342    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
 343    last_modified_time: Optional[datetime] = Field(
 344        default=None, alias="LastModifiedTime"
 345    )
 346
 347
 348class KeyValueModel(BaseModel):
 349    key: Optional[str] = Field(default=None, alias="Key")
 350    value: Optional[str] = Field(default=None, alias="Value")
 351
 352
 353class HadoopStepConfigModel(BaseModel):
 354    jar: Optional[str] = Field(default=None, alias="Jar")
 355    properties: Optional[Dict[str, str]] = Field(default=None, alias="Properties")
 356    main_class: Optional[str] = Field(default=None, alias="MainClass")
 357    args: Optional[List[str]] = Field(default=None, alias="Args")
 358
 359
 360class SpotProvisioningSpecificationModel(BaseModel):
 361    timeout_duration_minutes: int = Field(alias="TimeoutDurationMinutes")
 362    timeout_action: Literal["SWITCH_TO_ON_DEMAND", "TERMINATE_CLUSTER"] = Field(
 363        alias="TimeoutAction"
 364    )
 365    block_duration_minutes: Optional[int] = Field(
 366        default=None, alias="BlockDurationMinutes"
 367    )
 368    allocation_strategy: Optional[Literal["capacity-optimized"]] = Field(
 369        default=None, alias="AllocationStrategy"
 370    )
 371
 372
 373class OnDemandResizingSpecificationModel(BaseModel):
 374    timeout_duration_minutes: int = Field(alias="TimeoutDurationMinutes")
 375
 376
 377class SpotResizingSpecificationModel(BaseModel):
 378    timeout_duration_minutes: int = Field(alias="TimeoutDurationMinutes")
 379
 380
 381class InstanceFleetStateChangeReasonModel(BaseModel):
 382    code: Optional[
 383        Literal[
 384            "CLUSTER_TERMINATED",
 385            "INSTANCE_FAILURE",
 386            "INTERNAL_ERROR",
 387            "VALIDATION_ERROR",
 388        ]
 389    ] = Field(default=None, alias="Code")
 390    message: Optional[str] = Field(default=None, alias="Message")
 391
 392
 393class InstanceFleetTimelineModel(BaseModel):
 394    creation_date_time: Optional[datetime] = Field(
 395        default=None, alias="CreationDateTime"
 396    )
 397    ready_date_time: Optional[datetime] = Field(default=None, alias="ReadyDateTime")
 398    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 399
 400
 401class InstanceGroupDetailModel(BaseModel):
 402    market: Literal["ON_DEMAND", "SPOT"] = Field(alias="Market")
 403    instance_role: Literal["CORE", "MASTER", "TASK"] = Field(alias="InstanceRole")
 404    instance_type: str = Field(alias="InstanceType")
 405    instance_request_count: int = Field(alias="InstanceRequestCount")
 406    instance_running_count: int = Field(alias="InstanceRunningCount")
 407    state: Literal[
 408        "ARRESTED",
 409        "BOOTSTRAPPING",
 410        "ENDED",
 411        "PROVISIONING",
 412        "RECONFIGURING",
 413        "RESIZING",
 414        "RUNNING",
 415        "SHUTTING_DOWN",
 416        "SUSPENDED",
 417        "TERMINATED",
 418        "TERMINATING",
 419    ] = Field(alias="State")
 420    creation_date_time: datetime = Field(alias="CreationDateTime")
 421    instance_group_id: Optional[str] = Field(default=None, alias="InstanceGroupId")
 422    name: Optional[str] = Field(default=None, alias="Name")
 423    bid_price: Optional[str] = Field(default=None, alias="BidPrice")
 424    last_state_change_reason: Optional[str] = Field(
 425        default=None, alias="LastStateChangeReason"
 426    )
 427    start_date_time: Optional[datetime] = Field(default=None, alias="StartDateTime")
 428    ready_date_time: Optional[datetime] = Field(default=None, alias="ReadyDateTime")
 429    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 430    custom_ami_id: Optional[str] = Field(default=None, alias="CustomAmiId")
 431
 432
 433class InstanceGroupStateChangeReasonModel(BaseModel):
 434    code: Optional[
 435        Literal[
 436            "CLUSTER_TERMINATED",
 437            "INSTANCE_FAILURE",
 438            "INTERNAL_ERROR",
 439            "VALIDATION_ERROR",
 440        ]
 441    ] = Field(default=None, alias="Code")
 442    message: Optional[str] = Field(default=None, alias="Message")
 443
 444
 445class InstanceGroupTimelineModel(BaseModel):
 446    creation_date_time: Optional[datetime] = Field(
 447        default=None, alias="CreationDateTime"
 448    )
 449    ready_date_time: Optional[datetime] = Field(default=None, alias="ReadyDateTime")
 450    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 451
 452
 453class InstanceResizePolicyModel(BaseModel):
 454    instances_to_terminate: Optional[List[str]] = Field(
 455        default=None, alias="InstancesToTerminate"
 456    )
 457    instances_to_protect: Optional[List[str]] = Field(
 458        default=None, alias="InstancesToProtect"
 459    )
 460    instance_termination_timeout: Optional[int] = Field(
 461        default=None, alias="InstanceTerminationTimeout"
 462    )
 463
 464
 465class InstanceStateChangeReasonModel(BaseModel):
 466    code: Optional[
 467        Literal[
 468            "BOOTSTRAP_FAILURE",
 469            "CLUSTER_TERMINATED",
 470            "INSTANCE_FAILURE",
 471            "INTERNAL_ERROR",
 472            "VALIDATION_ERROR",
 473        ]
 474    ] = Field(default=None, alias="Code")
 475    message: Optional[str] = Field(default=None, alias="Message")
 476
 477
 478class InstanceTimelineModel(BaseModel):
 479    creation_date_time: Optional[datetime] = Field(
 480        default=None, alias="CreationDateTime"
 481    )
 482    ready_date_time: Optional[datetime] = Field(default=None, alias="ReadyDateTime")
 483    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 484
 485
 486class JobFlowExecutionStatusDetailModel(BaseModel):
 487    state: Literal[
 488        "BOOTSTRAPPING",
 489        "COMPLETED",
 490        "FAILED",
 491        "RUNNING",
 492        "SHUTTING_DOWN",
 493        "STARTING",
 494        "TERMINATED",
 495        "WAITING",
 496    ] = Field(alias="State")
 497    creation_date_time: datetime = Field(alias="CreationDateTime")
 498    start_date_time: Optional[datetime] = Field(default=None, alias="StartDateTime")
 499    ready_date_time: Optional[datetime] = Field(default=None, alias="ReadyDateTime")
 500    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 501    last_state_change_reason: Optional[str] = Field(
 502        default=None, alias="LastStateChangeReason"
 503    )
 504
 505
 506class PlacementTypeModel(BaseModel):
 507    availability_zone: Optional[str] = Field(default=None, alias="AvailabilityZone")
 508    availability_zones: Optional[List[str]] = Field(
 509        default=None, alias="AvailabilityZones"
 510    )
 511
 512
 513class PaginatorConfigModel(BaseModel):
 514    max_items: Optional[int] = Field(default=None, alias="MaxItems")
 515    page_size: Optional[int] = Field(default=None, alias="PageSize")
 516    starting_token: Optional[str] = Field(default=None, alias="StartingToken")
 517
 518
 519class ListBootstrapActionsInputRequestModel(BaseModel):
 520    cluster_id: str = Field(alias="ClusterId")
 521    marker: Optional[str] = Field(default=None, alias="Marker")
 522
 523
 524class ListClustersInputRequestModel(BaseModel):
 525    created_after: Optional[Union[datetime, str]] = Field(
 526        default=None, alias="CreatedAfter"
 527    )
 528    created_before: Optional[Union[datetime, str]] = Field(
 529        default=None, alias="CreatedBefore"
 530    )
 531    cluster_states: Optional[
 532        Sequence[
 533            Literal[
 534                "BOOTSTRAPPING",
 535                "RUNNING",
 536                "STARTING",
 537                "TERMINATED",
 538                "TERMINATED_WITH_ERRORS",
 539                "TERMINATING",
 540                "WAITING",
 541            ]
 542        ]
 543    ] = Field(default=None, alias="ClusterStates")
 544    marker: Optional[str] = Field(default=None, alias="Marker")
 545
 546
 547class ListInstanceFleetsInputRequestModel(BaseModel):
 548    cluster_id: str = Field(alias="ClusterId")
 549    marker: Optional[str] = Field(default=None, alias="Marker")
 550
 551
 552class ListInstanceGroupsInputRequestModel(BaseModel):
 553    cluster_id: str = Field(alias="ClusterId")
 554    marker: Optional[str] = Field(default=None, alias="Marker")
 555
 556
 557class ListInstancesInputRequestModel(BaseModel):
 558    cluster_id: str = Field(alias="ClusterId")
 559    instance_group_id: Optional[str] = Field(default=None, alias="InstanceGroupId")
 560    instance_group_types: Optional[Sequence[Literal["CORE", "MASTER", "TASK"]]] = Field(
 561        default=None, alias="InstanceGroupTypes"
 562    )
 563    instance_fleet_id: Optional[str] = Field(default=None, alias="InstanceFleetId")
 564    instance_fleet_type: Optional[Literal["CORE", "MASTER", "TASK"]] = Field(
 565        default=None, alias="InstanceFleetType"
 566    )
 567    instance_states: Optional[
 568        Sequence[
 569            Literal[
 570                "AWAITING_FULFILLMENT",
 571                "BOOTSTRAPPING",
 572                "PROVISIONING",
 573                "RUNNING",
 574                "TERMINATED",
 575            ]
 576        ]
 577    ] = Field(default=None, alias="InstanceStates")
 578    marker: Optional[str] = Field(default=None, alias="Marker")
 579
 580
 581class ListNotebookExecutionsInputRequestModel(BaseModel):
 582    editor_id: Optional[str] = Field(default=None, alias="EditorId")
 583    status: Optional[
 584        Literal[
 585            "FAILED",
 586            "FAILING",
 587            "FINISHED",
 588            "FINISHING",
 589            "RUNNING",
 590            "STARTING",
 591            "START_PENDING",
 592            "STOPPED",
 593            "STOPPING",
 594            "STOP_PENDING",
 595        ]
 596    ] = Field(default=None, alias="Status")
 597    from_: Optional[Union[datetime, str]] = Field(default=None, alias="From")
 598    to: Optional[Union[datetime, str]] = Field(default=None, alias="To")
 599    marker: Optional[str] = Field(default=None, alias="Marker")
 600
 601
 602class NotebookExecutionSummaryModel(BaseModel):
 603    notebook_execution_id: Optional[str] = Field(
 604        default=None, alias="NotebookExecutionId"
 605    )
 606    editor_id: Optional[str] = Field(default=None, alias="EditorId")
 607    notebook_execution_name: Optional[str] = Field(
 608        default=None, alias="NotebookExecutionName"
 609    )
 610    status: Optional[
 611        Literal[
 612            "FAILED",
 613            "FAILING",
 614            "FINISHED",
 615            "FINISHING",
 616            "RUNNING",
 617            "STARTING",
 618            "START_PENDING",
 619            "STOPPED",
 620            "STOPPING",
 621            "STOP_PENDING",
 622        ]
 623    ] = Field(default=None, alias="Status")
 624    start_time: Optional[datetime] = Field(default=None, alias="StartTime")
 625    end_time: Optional[datetime] = Field(default=None, alias="EndTime")
 626
 627
 628class ReleaseLabelFilterModel(BaseModel):
 629    prefix: Optional[str] = Field(default=None, alias="Prefix")
 630    application: Optional[str] = Field(default=None, alias="Application")
 631
 632
 633class ListSecurityConfigurationsInputRequestModel(BaseModel):
 634    marker: Optional[str] = Field(default=None, alias="Marker")
 635
 636
 637class SecurityConfigurationSummaryModel(BaseModel):
 638    name: Optional[str] = Field(default=None, alias="Name")
 639    creation_date_time: Optional[datetime] = Field(
 640        default=None, alias="CreationDateTime"
 641    )
 642
 643
 644class ListStepsInputRequestModel(BaseModel):
 645    cluster_id: str = Field(alias="ClusterId")
 646    step_states: Optional[
 647        Sequence[
 648            Literal[
 649                "CANCELLED",
 650                "CANCEL_PENDING",
 651                "COMPLETED",
 652                "FAILED",
 653                "INTERRUPTED",
 654                "PENDING",
 655                "RUNNING",
 656            ]
 657        ]
 658    ] = Field(default=None, alias="StepStates")
 659    step_ids: Optional[Sequence[str]] = Field(default=None, alias="StepIds")
 660    marker: Optional[str] = Field(default=None, alias="Marker")
 661
 662
 663class ListStudioSessionMappingsInputRequestModel(BaseModel):
 664    studio_id: Optional[str] = Field(default=None, alias="StudioId")
 665    identity_type: Optional[Literal["GROUP", "USER"]] = Field(
 666        default=None, alias="IdentityType"
 667    )
 668    marker: Optional[str] = Field(default=None, alias="Marker")
 669
 670
 671class SessionMappingSummaryModel(BaseModel):
 672    studio_id: Optional[str] = Field(default=None, alias="StudioId")
 673    identity_id: Optional[str] = Field(default=None, alias="IdentityId")
 674    identity_name: Optional[str] = Field(default=None, alias="IdentityName")
 675    identity_type: Optional[Literal["GROUP", "USER"]] = Field(
 676        default=None, alias="IdentityType"
 677    )
 678    session_policy_arn: Optional[str] = Field(default=None, alias="SessionPolicyArn")
 679    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
 680
 681
 682class ListStudiosInputRequestModel(BaseModel):
 683    marker: Optional[str] = Field(default=None, alias="Marker")
 684
 685
 686class StudioSummaryModel(BaseModel):
 687    studio_id: Optional[str] = Field(default=None, alias="StudioId")
 688    name: Optional[str] = Field(default=None, alias="Name")
 689    vpc_id: Optional[str] = Field(default=None, alias="VpcId")
 690    description: Optional[str] = Field(default=None, alias="Description")
 691    url: Optional[str] = Field(default=None, alias="Url")
 692    auth_mode: Optional[Literal["IAM", "SSO"]] = Field(default=None, alias="AuthMode")
 693    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
 694
 695
 696class ModifyClusterInputRequestModel(BaseModel):
 697    cluster_id: str = Field(alias="ClusterId")
 698    step_concurrency_level: Optional[int] = Field(
 699        default=None, alias="StepConcurrencyLevel"
 700    )
 701
 702
 703class OnDemandCapacityReservationOptionsModel(BaseModel):
 704    usage_strategy: Optional[Literal["use-capacity-reservations-first"]] = Field(
 705        default=None, alias="UsageStrategy"
 706    )
 707    capacity_reservation_preference: Optional[Literal["none", "open"]] = Field(
 708        default=None, alias="CapacityReservationPreference"
 709    )
 710    capacity_reservation_resource_group_arn: Optional[str] = Field(
 711        default=None, alias="CapacityReservationResourceGroupArn"
 712    )
 713
 714
 715class RemoveAutoScalingPolicyInputRequestModel(BaseModel):
 716    cluster_id: str = Field(alias="ClusterId")
 717    instance_group_id: str = Field(alias="InstanceGroupId")
 718
 719
 720class RemoveAutoTerminationPolicyInputRequestModel(BaseModel):
 721    cluster_id: str = Field(alias="ClusterId")
 722
 723
 724class RemoveManagedScalingPolicyInputRequestModel(BaseModel):
 725    cluster_id: str = Field(alias="ClusterId")
 726
 727
 728class RemoveTagsInputRequestModel(BaseModel):
 729    resource_id: str = Field(alias="ResourceId")
 730    tag_keys: Sequence[str] = Field(alias="TagKeys")
 731
 732
 733class SupportedProductConfigModel(BaseModel):
 734    name: Optional[str] = Field(default=None, alias="Name")
 735    args: Optional[Sequence[str]] = Field(default=None, alias="Args")
 736
 737
 738class SimpleScalingPolicyConfigurationModel(BaseModel):
 739    scaling_adjustment: int = Field(alias="ScalingAdjustment")
 740    adjustment_type: Optional[
 741        Literal["CHANGE_IN_CAPACITY", "EXACT_CAPACITY", "PERCENT_CHANGE_IN_CAPACITY"]
 742    ] = Field(default=None, alias="AdjustmentType")
 743    cool_down: Optional[int] = Field(default=None, alias="CoolDown")
 744
 745
 746class SetTerminationProtectionInputRequestModel(BaseModel):
 747    job_flow_ids: Sequence[str] = Field(alias="JobFlowIds")
 748    termination_protected: bool = Field(alias="TerminationProtected")
 749
 750
 751class SetVisibleToAllUsersInputRequestModel(BaseModel):
 752    job_flow_ids: Sequence[str] = Field(alias="JobFlowIds")
 753    visible_to_all_users: bool = Field(alias="VisibleToAllUsers")
 754
 755
 756class StepExecutionStatusDetailModel(BaseModel):
 757    state: Literal[
 758        "CANCELLED",
 759        "COMPLETED",
 760        "CONTINUE",
 761        "FAILED",
 762        "INTERRUPTED",
 763        "PENDING",
 764        "RUNNING",
 765    ] = Field(alias="State")
 766    creation_date_time: datetime = Field(alias="CreationDateTime")
 767    start_date_time: Optional[datetime] = Field(default=None, alias="StartDateTime")
 768    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 769    last_state_change_reason: Optional[str] = Field(
 770        default=None, alias="LastStateChangeReason"
 771    )
 772
 773
 774class StepStateChangeReasonModel(BaseModel):
 775    code: Optional[Literal["NONE"]] = Field(default=None, alias="Code")
 776    message: Optional[str] = Field(default=None, alias="Message")
 777
 778
 779class StepTimelineModel(BaseModel):
 780    creation_date_time: Optional[datetime] = Field(
 781        default=None, alias="CreationDateTime"
 782    )
 783    start_date_time: Optional[datetime] = Field(default=None, alias="StartDateTime")
 784    end_date_time: Optional[datetime] = Field(default=None, alias="EndDateTime")
 785
 786
 787class StopNotebookExecutionInputRequestModel(BaseModel):
 788    notebook_execution_id: str = Field(alias="NotebookExecutionId")
 789
 790
 791class TerminateJobFlowsInputRequestModel(BaseModel):
 792    job_flow_ids: Sequence[str] = Field(alias="JobFlowIds")
 793
 794
 795class UpdateStudioInputRequestModel(BaseModel):
 796    studio_id: str = Field(alias="StudioId")
 797    name: Optional[str] = Field(default=None, alias="Name")
 798    description: Optional[str] = Field(default=None, alias="Description")
 799    subnet_ids: Optional[Sequence[str]] = Field(default=None, alias="SubnetIds")
 800    default_s3_location: Optional[str] = Field(default=None, alias="DefaultS3Location")
 801
 802
 803class UpdateStudioSessionMappingInputRequestModel(BaseModel):
 804    studio_id: str = Field(alias="StudioId")
 805    identity_type: Literal["GROUP", "USER"] = Field(alias="IdentityType")
 806    session_policy_arn: str = Field(alias="SessionPolicyArn")
 807    identity_id: Optional[str] = Field(default=None, alias="IdentityId")
 808    identity_name: Optional[str] = Field(default=None, alias="IdentityName")
 809
 810
 811class AddInstanceFleetOutputModel(BaseModel):
 812    cluster_id: str = Field(alias="ClusterId")
 813    instance_fleet_id: str = Field(alias="InstanceFleetId")
 814    cluster_arn: str = Field(alias="ClusterArn")
 815    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 816
 817
 818class AddInstanceGroupsOutputModel(BaseModel):
 819    job_flow_id: str = Field(alias="JobFlowId")
 820    instance_group_ids: List[str] = Field(alias="InstanceGroupIds")
 821    cluster_arn: str = Field(alias="ClusterArn")
 822    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 823
 824
 825class AddJobFlowStepsOutputModel(BaseModel):
 826    step_ids: List[str] = Field(alias="StepIds")
 827    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 828
 829
 830class CreateSecurityConfigurationOutputModel(BaseModel):
 831    name: str = Field(alias="Name")
 832    creation_date_time: datetime = Field(alias="CreationDateTime")
 833    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 834
 835
 836class CreateStudioOutputModel(BaseModel):
 837    studio_id: str = Field(alias="StudioId")
 838    url: str = Field(alias="Url")
 839    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 840
 841
 842class DescribeSecurityConfigurationOutputModel(BaseModel):
 843    name: str = Field(alias="Name")
 844    security_configuration: str = Field(alias="SecurityConfiguration")
 845    creation_date_time: datetime = Field(alias="CreationDateTime")
 846    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 847
 848
 849class EmptyResponseMetadataModel(BaseModel):
 850    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 851
 852
 853class ListReleaseLabelsOutputModel(BaseModel):
 854    release_labels: List[str] = Field(alias="ReleaseLabels")
 855    next_token: str = Field(alias="NextToken")
 856    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 857
 858
 859class ModifyClusterOutputModel(BaseModel):
 860    step_concurrency_level: int = Field(alias="StepConcurrencyLevel")
 861    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 862
 863
 864class RunJobFlowOutputModel(BaseModel):
 865    job_flow_id: str = Field(alias="JobFlowId")
 866    cluster_arn: str = Field(alias="ClusterArn")
 867    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 868
 869
 870class StartNotebookExecutionOutputModel(BaseModel):
 871    notebook_execution_id: str = Field(alias="NotebookExecutionId")
 872    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 873
 874
 875class AddTagsInputRequestModel(BaseModel):
 876    resource_id: str = Field(alias="ResourceId")
 877    tags: Sequence[TagModel] = Field(alias="Tags")
 878
 879
 880class CreateStudioInputRequestModel(BaseModel):
 881    name: str = Field(alias="Name")
 882    auth_mode: Literal["IAM", "SSO"] = Field(alias="AuthMode")
 883    vpc_id: str = Field(alias="VpcId")
 884    subnet_ids: Sequence[str] = Field(alias="SubnetIds")
 885    service_role: str = Field(alias="ServiceRole")
 886    workspace_security_group_id: str = Field(alias="WorkspaceSecurityGroupId")
 887    engine_security_group_id: str = Field(alias="EngineSecurityGroupId")
 888    default_s3_location: str = Field(alias="DefaultS3Location")
 889    description: Optional[str] = Field(default=None, alias="Description")
 890    user_role: Optional[str] = Field(default=None, alias="UserRole")
 891    idp_auth_url: Optional[str] = Field(default=None, alias="IdpAuthUrl")
 892    idp_relay_state_parameter_name: Optional[str] = Field(
 893        default=None, alias="IdpRelayStateParameterName"
 894    )
 895    tags: Optional[Sequence[TagModel]] = Field(default=None, alias="Tags")
 896
 897
 898class StudioModel(BaseModel):
 899    studio_id: Optional[str] = Field(default=None, alias="StudioId")
 900    studio_arn: Optional[str] = Field(default=None, alias="StudioArn")
 901    name: Optional[str] = Field(default=None, alias="Name")
 902    description: Optional[str] = Field(default=None, alias="Description")
 903    auth_mode: Optional[Literal["IAM", "SSO"]] = Field(default=None, alias="AuthMode")
 904    vpc_id: Optional[str] = Field(default=None, alias="VpcId")
 905    subnet_ids: Optional[List[str]] = Field(default=None, alias="SubnetIds")
 906    service_role: Optional[str] = Field(default=None, alias="ServiceRole")
 907    user_role: Optional[str] = Field(default=None, alias="UserRole")
 908    workspace_security_group_id: Optional[str] = Field(
 909        default=None, alias="WorkspaceSecurityGroupId"
 910    )
 911    engine_security_group_id: Optional[str] = Field(
 912        default=None, alias="EngineSecurityGroupId"
 913    )
 914    url: Optional[str] = Field(default=None, alias="Url")
 915    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
 916    default_s3_location: Optional[str] = Field(default=None, alias="DefaultS3Location")
 917    idp_auth_url: Optional[str] = Field(default=None, alias="IdpAuthUrl")
 918    idp_relay_state_parameter_name: Optional[str] = Field(
 919        default=None, alias="IdpRelayStateParameterName"
 920    )
 921    tags: Optional[List[TagModel]] = Field(default=None, alias="Tags")
 922
 923
 924class AutoScalingPolicyStatusModel(BaseModel):
 925    state: Optional[
 926        Literal["ATTACHED", "ATTACHING", "DETACHED", "DETACHING", "FAILED", "PENDING"]
 927    ] = Field(default=None, alias="State")
 928    state_change_reason: Optional[AutoScalingPolicyStateChangeReasonModel] = Field(
 929        default=None, alias="StateChangeReason"
 930    )
 931
 932
 933class GetAutoTerminationPolicyOutputModel(BaseModel):
 934    auto_termination_policy: AutoTerminationPolicyModel = Field(
 935        alias="AutoTerminationPolicy"
 936    )
 937    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 938
 939
 940class PutAutoTerminationPolicyInputRequestModel(BaseModel):
 941    cluster_id: str = Field(alias="ClusterId")
 942    auto_termination_policy: Optional[AutoTerminationPolicyModel] = Field(
 943        default=None, alias="AutoTerminationPolicy"
 944    )
 945
 946
 947class BlockPublicAccessConfigurationModel(BaseModel):
 948    block_public_security_group_rules: bool = Field(
 949        alias="BlockPublicSecurityGroupRules"
 950    )
 951    permitted_public_security_group_rule_ranges: Optional[List[PortRangeModel]] = Field(
 952        default=None, alias="PermittedPublicSecurityGroupRuleRanges"
 953    )
 954
 955
 956class BootstrapActionConfigModel(BaseModel):
 957    name: str = Field(alias="Name")
 958    script_bootstrap_action: ScriptBootstrapActionConfigModel = Field(
 959        alias="ScriptBootstrapAction"
 960    )
 961
 962
 963class CancelStepsOutputModel(BaseModel):
 964    cancel_steps_info_list: List[CancelStepsInfoModel] = Field(
 965        alias="CancelStepsInfoList"
 966    )
 967    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 968
 969
 970class CloudWatchAlarmDefinitionModel(BaseModel):
 971    comparison_operator: Literal[
 972        "GREATER_THAN", "GREATER_THAN_OR_EQUAL", "LESS_THAN", "LESS_THAN_OR_EQUAL"
 973    ] = Field(alias="ComparisonOperator")
 974    metric_name: str = Field(alias="MetricName")
 975    period: int = Field(alias="Period")
 976    threshold: float = Field(alias="Threshold")
 977    evaluation_periods: Optional[int] = Field(default=None, alias="EvaluationPeriods")
 978    namespace: Optional[str] = Field(default=None, alias="Namespace")
 979    statistic: Optional[
 980        Literal["AVERAGE", "MAXIMUM", "MINIMUM", "SAMPLE_COUNT", "SUM"]
 981    ] = Field(default=None, alias="Statistic")
 982    unit: Optional[
 983        Literal[
 984            "BITS",
 985            "BITS_PER_SECOND",
 986            "BYTES",
 987            "BYTES_PER_SECOND",
 988            "COUNT",
 989            "COUNT_PER_SECOND",
 990            "GIGA_BITS",
 991            "GIGA_BITS_PER_SECOND",
 992            "GIGA_BYTES",
 993            "GIGA_BYTES_PER_SECOND",
 994            "KILO_BITS",
 995            "KILO_BITS_PER_SECOND",
 996            "KILO_BYTES",
 997            "KILO_BYTES_PER_SECOND",
 998            "MEGA_BITS",
 999            "MEGA_BITS_PER_SECOND",
1000            "MEGA_BYTES",
1001            "MEGA_BYTES_PER_SECOND",
1002            "MICRO_SECONDS",
1003            "MILLI_SECONDS",
1004            "NONE",
1005            "PERCENT",
1006            "SECONDS",
1007            "TERA_BITS",
1008            "TERA_BITS_PER_SECOND",
1009            "TERA_BYTES",
1010            "TERA_BYTES_PER_SECOND",
1011        ]
1012    ] = Field(default=None, alias="Unit")
1013    dimensions: Optional[Sequence[MetricDimensionModel]] = Field(
1014        default=None, alias="Dimensions"
1015    )
1016
1017
1018class ClusterStatusModel(BaseModel):
1019    state: Optional[
1020        Literal[
1021            "BOOTSTRAPPING",
1022            "RUNNING",
1023            "STARTING",
1024            "TERMINATED",
1025            "TERMINATED_WITH_ERRORS",
1026            "TERMINATING",
1027            "WAITING",
1028        ]
1029    ] = Field(default=None, alias="State")
1030    state_change_reason: Optional[ClusterStateChangeReasonModel] = Field(
1031        default=None, alias="StateChangeReason"
1032    )
1033    timeline: Optional[ClusterTimelineModel] = Field(default=None, alias="Timeline")
1034
1035
1036class ListBootstrapActionsOutputModel(BaseModel):
1037    bootstrap_actions: List[CommandModel] = Field(alias="BootstrapActions")
1038    marker: str = Field(alias="Marker")
1039    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1040
1041
1042class ManagedScalingPolicyModel(BaseModel):
1043    compute_limits: Optional[ComputeLimitsModel] = Field(
1044        default=None, alias="ComputeLimits"
1045    )
1046
1047
1048class CredentialsModel(BaseModel):
1049    username_password: Optional[UsernamePasswordModel] = Field(
1050        default=None, alias="UsernamePassword"
1051    )
1052
1053
1054class DescribeClusterInputClusterRunningWaitModel(BaseModel):
1055    cluster_id: str = Field(alias="ClusterId")
1056    waiter_config: Optional[WaiterConfigModel] = Field(
1057        default=None, alias="WaiterConfig"
1058    )
1059
1060
1061class DescribeClusterInputClusterTerminatedWaitModel(BaseModel):
1062    cluster_id: str = Field(alias="ClusterId")
1063    waiter_config: Optional[WaiterConfigModel] = Field(
1064        default=None, alias="WaiterConfig"
1065    )
1066
1067
1068class DescribeStepInputStepCompleteWaitModel(BaseModel):
1069    cluster_id: str = Field(alias="ClusterId")
1070    step_id: str = Field(alias="StepId")
1071    waiter_config: Optional[WaiterConfigModel] = Field(
1072        default=None, alias="WaiterConfig"
1073    )
1074
1075
1076class DescribeReleaseLabelOutputModel(BaseModel):
1077    release_label: str = Field(alias="ReleaseLabel")
1078    applications: List[SimplifiedApplicationModel] = Field(alias="Applications")
1079    next_token: str = Field(alias="NextToken")
1080    available_os_releases: List[OSReleaseModel] = Field(alias="AvailableOSReleases")
1081    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1082
1083
1084class EbsBlockDeviceConfigModel(BaseModel):
1085    volume_specification: VolumeSpecificationModel = Field(alias="VolumeSpecification")
1086    volumes_per_instance: Optional[int] = Field(
1087        default=None, alias="VolumesPerInstance"
1088    )
1089
1090
1091class EbsBlockDeviceModel(BaseModel):
1092    volume_specification: Optional[VolumeSpecificationModel] = Field(
1093        default=None, alias="VolumeSpecification"
1094    )
1095    device: Optional[str] = Field(default=None, alias="Device")
1096
1097
1098class NotebookExecutionModel(BaseModel):
1099    notebook_execution_id: Optional[str] = Field(
1100        default=None, alias="NotebookExecutionId"
1101    )
1102    editor_id: Optional[str] = Field(default=None, alias="EditorId")
1103    execution_engine: Optional[ExecutionEngineConfigModel] = Field(
1104        default=None, alias="ExecutionEngine"
1105    )
1106    notebook_execution_name: Optional[str] = Field(
1107        default=None, alias="NotebookExecutionName"
1108    )
1109    notebook_params: Optional[str] = Field(default=None, alias="NotebookParams")
1110    status: Optional[
1111        Literal[
1112            "FAILED",
1113            "FAILING",
1114            "FINISHED",
1115            "FINISHING",
1116            "RUNNING",
1117            "STARTING",
1118            "START_PENDING",
1119            "STOPPED",
1120            "STOPPING",
1121            "STOP_PENDING",
1122        ]
1123    ] = Field(default=None, alias="Status")
1124    start_time: Optional[datetime] = Field(default=None, alias="StartTime")
1125    end_time: Optional[datetime] = Field(default=None, alias="EndTime")
1126    arn: Optional[str] = Field(default=None, alias="Arn")
1127    output_notebook_uri: Optional[str] = Field(default=None, alias="OutputNotebookURI")
1128    last_state_change_reason: Optional[str] = Field(
1129        default=None, alias="LastStateChangeReason"
1130    )
1131    notebook_instance_security_group_id: Optional[str] = Field(
1132        default=None, alias="NotebookInstanceSecurityGroupId"
1133    )
1134    tags: Optional[List[TagModel]] = Field(default=None, alias="Tags")
1135
1136
1137class StartNotebookExecutionInputRequestModel(BaseModel):
1138    editor_id: str = Field(alias="EditorId")
1139    relative_path: str = Field(alias="RelativePath")
1140    execution_engine: ExecutionEngineConfigModel = Field(alias="ExecutionEngine")
1141    service_role: str = Field(alias="ServiceRole")
1142    notebook_execution_name: Optional[str] = Field(
1143        default=None, alias="NotebookExecutionName"
1144    )
1145    notebook_params: Optional[str] = Field(default=None, alias="NotebookParams")
1146    notebook_instance_security_group_id: Optional[str] = Field(
1147        default=None, alias="NotebookInstanceSecurityGroupId"
1148    )
1149    tags: Optional[Sequence[TagModel]] = Field(default=None, alias="Tags")
1150
1151
1152class GetStudioSessionMappingOutputModel(BaseModel):
1153    session_mapping: SessionMappingDetailModel = Field(alias="SessionMapping")
1154    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1155
1156
1157class HadoopJarStepConfigModel(BaseModel):
1158    jar: str = Field(alias="Jar")
1159    properties: Optional[Sequence[KeyValueModel]] = Field(
1160        default=None, alias="Properties"
1161    )
1162    main_class: Optional[str] = Field(default=None, alias="MainClass")
1163    args: Optional[Sequence[str]] = Field(default=None, alias="Args")
1164
1165
1166class InstanceFleetResizingSpecificationsModel(BaseModel):
1167    spot_resize_specification: Optional[SpotResizingSpecificationModel] = Field(
1168        default=None, alias="SpotResizeSpecification"
1169    )
1170    on_demand_resize_specification: Optional[
1171        OnDemandResizingSpecificationModel
1172    ] = Field(default=None, alias="OnDemandResizeSpecification")
1173
1174
1175class InstanceFleetStatusModel(BaseModel):
1176    state: Optional[
1177        Literal[
1178            "BOOTSTRAPPING",
1179            "PROVISIONING",
1180            "RESIZING",
1181            "RUNNING",
1182            "SUSPENDED",
1183            "TERMINATED",
1184            "TERMINATING",
1185        ]
1186    ] = Field(default=None, alias="State")
1187    state_change_reason: Optional[InstanceFleetStateChangeReasonModel] = Field(
1188        default=None, alias="StateChangeReason"
1189    )
1190    timeline: Optional[InstanceFleetTimelineModel] = Field(
1191        default=None, alias="Timeline"
1192    )
1193
1194
1195class InstanceGroupStatusModel(BaseModel):
1196    state: Optional[
1197        Literal[
1198            "ARRESTED",
1199            "BOOTSTRAPPING",
1200            "ENDED",
1201            "PROVISIONING",
1202            "RECONFIGURING",
1203            "RESIZING",
1204            "RUNNING",
1205            "SHUTTING_DOWN",
1206            "SUSPENDED",
1207            "TERMINATED",
1208            "TERMINATING",
1209        ]
1210    ] = Field(default=None, alias="State")
1211    state_change_reason: Optional[InstanceGroupStateChangeReasonModel] = Field(
1212        default=None, alias="StateChangeReason"
1213    )
1214    timeline: Optional[InstanceGroupTimelineModel] = Field(
1215        default=None, alias="Timeline"
1216    )
1217
1218
1219class ShrinkPolicyModel(BaseModel):
1220    decommission_timeout: Optional[int] = Field(
1221        default=None, alias="DecommissionTimeout"
1222    )
1223    instance_resize_policy: Optional[InstanceResizePolicyModel] = Field(
1224        default=None, alias="InstanceResizePolicy"
1225    )
1226
1227
1228class InstanceStatusModel(BaseModel):
1229    state: Optional[
1230        Literal[
1231            "AWAITING_FULFILLMENT",
1232            "BOOTSTRAPPING",
1233            "PROVISIONING",
1234            "RUNNING",
1235            "TERMINATED",
1236        ]
1237    ] = Field(default=None, alias="State")
1238    state_change_reason: Optional[InstanceStateChangeReasonModel] = Field(
1239        default=None, alias="StateChangeReason"
1240    )
1241    timeline: Optional[InstanceTimelineModel] = Field(default=None, alias="Timeline")
1242
1243
1244class JobFlowInstancesDetailModel(BaseModel):
1245    master_instance_type: str = Field(alias="MasterInstanceType")
1246    slave_instance_type: str = Field(alias="SlaveInstanceType")
1247    instance_count: int = Field(alias="InstanceCount")
1248    master_public_dns_name: Optional[str] = Field(
1249        default=None, alias="MasterPublicDnsName"
1250    )
1251    master_instance_id: Optional[str] = Field(default=None, alias="MasterInstanceId")
1252    instance_groups: Optional[List[InstanceGroupDetailModel]] = Field(
1253        default=None, alias="InstanceGroups"
1254    )
1255    normalized_instance_hours: Optional[int] = Field(
1256        default=None, alias="NormalizedInstanceHours"
1257    )
1258    ec2_key_name: Optional[str] = Field(default=None, alias="Ec2KeyName")
1259    ec2_subnet_id: Optional[str] = Field(default=None, alias="Ec2SubnetId")
1260    placement: Optional[PlacementTypeModel] = Field(default=None, alias="Placement")
1261    keep_job_flow_alive_when_no_steps: Optional[bool] = Field(
1262        default=None, alias="KeepJobFlowAliveWhenNoSteps"
1263    )
1264    termination_protected: Optional[bool] = Field(
1265        default=None, alias="TerminationProtected"
1266    )
1267    hadoop_version: Optional[str] = Field(default=None, alias="HadoopVersion")
1268
1269
1270class ListBootstrapActionsInputListBootstrapActionsPaginateModel(BaseModel):
1271    cluster_id: str = Field(alias="ClusterId")
1272    pagination_config: Optional[PaginatorConfigModel] = Field(
1273        default=None, alias="PaginationConfig"
1274    )
1275
1276
1277class ListClustersInputListClustersPaginateModel(BaseModel):
1278    created_after: Optional[Union[datetime, str]] = Field(
1279        default=None, alias="CreatedAfter"
1280    )
1281    created_before: Optional[Union[datetime, str]] = Field(
1282        default=None, alias="CreatedBefore"
1283    )
1284    cluster_states: Optional[
1285        Sequence[
1286            Literal[
1287                "BOOTSTRAPPING",
1288                "RUNNING",
1289                "STARTING",
1290                "TERMINATED",
1291                "TERMINATED_WITH_ERRORS",
1292                "TERMINATING",
1293                "WAITING",
1294            ]
1295        ]
1296    ] = Field(default=None, alias="ClusterStates")
1297    pagination_config: Optional[PaginatorConfigModel] = Field(
1298        default=None, alias="PaginationConfig"
1299    )
1300
1301
1302class ListInstanceFleetsInputListInstanceFleetsPaginateModel(BaseModel):
1303    cluster_id: str = Field(alias="ClusterId")
1304    pagination_config: Optional[PaginatorConfigModel] = Field(
1305        default=None, alias="PaginationConfig"
1306    )
1307
1308
1309class ListInstanceGroupsInputListInstanceGroupsPaginateModel(BaseModel):
1310    cluster_id: str = Field(alias="ClusterId")
1311    pagination_config: Optional[PaginatorConfigModel] = Field(
1312        default=None, alias="PaginationConfig"
1313    )
1314
1315
1316class ListInstancesInputListInstancesPaginateModel(BaseModel):
1317    cluster_id: str = Field(alias="ClusterId")
1318    instance_group_id: Optional[str] = Field(default=None, alias="InstanceGroupId")
1319    instance_group_types: Optional[Sequence[Literal["CORE", "MASTER", "TASK"]]] = Field(
1320        default=None, alias="InstanceGroupTypes"
1321    )
1322    instance_fleet_id: Optional[str] = Field(default=None, alias="InstanceFleetId")
1323    instance_fleet_type: Optional[Literal["CORE", "MASTER", "TASK"]] = Field(
1324        default=None, alias="InstanceFleetType"
1325    )
1326    instance_states: Optional[
1327        Sequence[
1328            Literal[
1329                "AWAITING_FULFILLMENT",
1330                "BOOTSTRAPPING",
1331                "PROVISIONING",
1332                "RUNNING",
1333                "TERMINATED",
1334            ]
1335        ]
1336    ] = Field(default=None, alias="InstanceStates")
1337    pagination_config: Optional[PaginatorConfigModel] = Field(
1338        default=None, alias="PaginationConfig"
1339    )
1340
1341
1342class ListNotebookExecutionsInputListNotebookExecutionsPaginateModel(BaseModel):
1343    editor_id: Optional[str] = Field(default=None, alias="EditorId")
1344    status: Optional[
1345        Literal[
1346            "FAILED",
1347            "FAILING",
1348            "FINISHED",
1349            "FINISHING",
1350            "RUNNING",
1351            "STARTING",
1352            "START_PENDING",
1353            "STOPPED",
1354            "STOPPING",
1355            "STOP_PENDING",
1356        ]
1357    ] = Field(default=None, alias="Status")
1358    from_: Optional[Union[datetime, str]] = Field(default=None, alias="From")
1359    to: Optional[Union[datetime, str]] = Field(default=None, alias="To")
1360    pagination_config: Optional[PaginatorConfigModel] = Field(
1361        default=None, alias="PaginationConfig"
1362    )
1363
1364
1365class ListSecurityConfigurationsInputListSecurityConfigurationsPaginateModel(BaseModel):
1366    pagination_config: Optional[PaginatorConfigModel] = Field(
1367        default=None, alias="PaginationConfig"
1368    )
1369
1370
1371class ListStepsInputListStepsPaginateModel(BaseModel):
1372    cluster_id: str = Field(alias="ClusterId")
1373    step_states: Optional[
1374        Sequence[
1375            Literal[
1376                "CANCELLED",
1377                "CANCEL_PENDING",
1378                "COMPLETED",
1379                "FAILED",
1380                "INTERRUPTED",
1381                "PENDING",
1382                "RUNNING",
1383            ]
1384        ]
1385    ] = Field(default=None, alias="StepStates")
1386    step_ids: Optional[Sequence[str]] = Field(default=None, alias="StepIds")
1387    pagination_config: Optional[PaginatorConfigModel] = Field(
1388        default=None, alias="PaginationConfig"
1389    )
1390
1391
1392class ListStudioSessionMappingsInputListStudioSessionMappingsPaginateModel(BaseModel):
1393    studio_id: Optional[str] = Field(default=None, alias="StudioId")
1394    identity_type: Optional[Literal["GROUP", "USER"]] = Field(
1395        default=None, alias="IdentityType"
1396    )
1397    pagination_config: Optional[PaginatorConfigModel] = Field(
1398        default=None, alias="PaginationConfig"
1399    )
1400
1401
1402class ListStudiosInputListStudiosPaginateModel(BaseModel):
1403    pagination_config: Optional[PaginatorConfigModel] = Field(
1404        default=None, alias="PaginationConfig"
1405    )
1406
1407
1408class ListNotebookExecutionsOutputModel(BaseModel):
1409    notebook_executions: List[NotebookExecutionSummaryModel] = Field(
1410        alias="NotebookExecutions"
1411    )
1412    marker: str = Field(alias="Marker")
1413    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1414
1415
1416class ListReleaseLabelsInputRequestModel(BaseModel):
1417    filters: Optional[ReleaseLabelFilterModel] = Field(default=None, alias="Filters")
1418    next_token: Optional[str] = Field(default=None, alias="NextToken")
1419    max_results: Optional[int] = Field(default=None, alias="MaxResults")
1420
1421
1422class ListSecurityConfigurationsOutputModel(BaseModel):
1423    security_configurations: List[SecurityConfigurationSummaryModel] = Field(
1424        alias="SecurityConfigurations"
1425    )
1426    marker: str = Field(alias="Marker")
1427    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1428
1429
1430class ListStudioSessionMappingsOutputModel(BaseModel):
1431    session_mappings: List[SessionMappingSummaryModel] = Field(alias="SessionMappings")
1432    marker: str = Field(alias="Marker")
1433    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1434
1435
1436class ListStudiosOutputModel(BaseModel):
1437    studios: List[StudioSummaryModel] = Field(alias="Studios")
1438    marker: str = Field(alias="Marker")
1439    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1440
1441
1442class OnDemandProvisioningSpecificationModel(BaseModel):
1443    allocation_strategy: Literal["lowest-price"] = Field(alias="AllocationStrategy")
1444    capacity_reservation_options: Optional[
1445        OnDemandCapacityReservationOptionsModel
1446    ] = Field(default=None, alias="CapacityReservationOptions")
1447
1448
1449class ScalingActionModel(BaseModel):
1450    simple_scaling_policy_configuration: SimpleScalingPolicyConfigurationModel = Field(
1451        alias="SimpleScalingPolicyConfiguration"
1452    )
1453    market: Optional[Literal["ON_DEMAND", "SPOT"]] = Field(default=None, alias="Market")
1454
1455
1456class StepStatusModel(BaseModel):
1457    state: Optional[
1458        Literal[
1459            "CANCELLED",
1460            "CANCEL_PENDING",
1461            "COMPLETED",
1462            "FAILED",
1463            "INTERRUPTED",
1464            "PENDING",
1465            "RUNNING",
1466        ]
1467    ] = Field(default=None, alias="State")
1468    state_change_reason: Optional[StepStateChangeReasonModel] = Field(
1469        default=None, alias="StateChangeReason"
1470    )
1471    failure_details: Optional[FailureDetailsModel] = Field(
1472        default=None, alias="FailureDetails"
1473    )
1474    timeline: Optional[StepTimelineModel] = Field(default=None, alias="Timeline")
1475
1476
1477class DescribeStudioOutputModel(BaseModel):
1478    studio: StudioModel = Field(alias="Studio")
1479    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1480
1481
1482class GetBlockPublicAccessConfigurationOutputModel(BaseModel):
1483    block_public_access_configuration: BlockPublicAccessConfigurationModel = Field(
1484        alias="BlockPublicAccessConfiguration"
1485    )
1486    block_public_access_configuration_metadata: BlockPublicAccessConfigurationMetadataModel = Field(
1487        alias="BlockPublicAccessConfigurationMetadata"
1488    )
1489    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1490
1491
1492class PutBlockPublicAccessConfigurationInputRequestModel(BaseModel):
1493    block_public_access_configuration: BlockPublicAccessConfigurationModel = Field(
1494        alias="BlockPublicAccessConfiguration"
1495    )
1496
1497
1498class BootstrapActionDetailModel(BaseModel):
1499    bootstrap_action_config: Optional[BootstrapActionConfigModel] = Field(
1500        default=None, alias="BootstrapActionConfig"
1501    )
1502
1503
1504class ScalingTriggerModel(BaseModel):
1505    cloud_watch_alarm_definition: CloudWatchAlarmDefinitionModel = Field(
1506        alias="CloudWatchAlarmDefinition"
1507    )
1508
1509
1510class ClusterSummaryModel(BaseModel):
1511    id: Optional[str] = Field(default=None, alias="Id")
1512    name: Optional[str] = Field(default=None, alias="Name")
1513    status: Optional[ClusterStatusModel] = Field(default=None, alias="Status")
1514    normalized_instance_hours: Optional[int] = Field(
1515        default=None, alias="NormalizedInstanceHours"
1516    )
1517    cluster_arn: Optional[str] = Field(default=None, alias="ClusterArn")
1518    outpost_arn: Optional[str] = Field(default=None, alias="OutpostArn")
1519
1520
1521class ClusterModel(BaseModel):
1522    id: Optional[str] = Field(default=None, alias="Id")
1523    name: Optional[str] = Field(default=None, alias="Name")
1524    status: Optional[ClusterStatusModel] = Field(default=None, alias="Status")
1525    ec2_instance_attributes: Optional[Ec2InstanceAttributesModel] = Field(
1526        default=None, alias="Ec2InstanceAttributes"
1527    )
1528    instance_collection_type: Optional[
1529        Literal["INSTANCE_FLEET", "INSTANCE_GROUP"]
1530    ] = Field(default=None, alias="InstanceCollectionType")
1531    log_uri: Optional[str] = Field(default=None, alias="LogUri")
1532    log_encryption_kms_key_id: Optional[str] = Field(
1533        default=None, alias="LogEncryptionKmsKeyId"
1534    )
1535    requested_ami_version: Optional[str] = Field(
1536        default=None, alias="RequestedAmiVersion"
1537    )
1538    running_ami_version: Optional[str] = Field(default=None, alias="RunningAmiVersion")
1539    release_label: Optional[str] = Field(default=None, alias="ReleaseLabel")
1540    auto_terminate: Optional[bool] = Field(default=None, alias="AutoTerminate")
1541    termination_protected: Optional[bool] = Field(
1542        default=None, alias="TerminationProtected"
1543    )
1544    visible_to_all_users: Optional[bool] = Field(
1545        default=None, alias="VisibleToAllUsers"
1546    )
1547    applications: Optional[List[ApplicationModel]] = Field(
1548        default=None, alias="Applications"
1549    )
1550    tags: Optional[List[TagModel]] = Field(default=None, alias="Tags")
1551    service_role: Optional[str] = Field(default=None, alias="ServiceRole")
1552    normalized_instance_hours: Optional[int] = Field(
1553        default=None, alias="NormalizedInstanceHours"
1554    )
1555    master_public_dns_name: Optional[str] = Field(
1556        default=None, alias="MasterPublicDnsName"
1557    )
1558    configurations: Optional[List[ConfigurationModel]] = Field(
1559        default=None, alias="Configurations"
1560    )
1561    security_configuration: Optional[str] = Field(
1562        default=None, alias="SecurityConfiguration"
1563    )
1564    auto_scaling_role: Optional[str] = Field(default=None, alias="AutoScalingRole")
1565    scale_down_behavior: Optional[
1566        Literal["TERMINATE_AT_INSTANCE_HOUR", "TERMINATE_AT_TASK_COMPLETION"]
1567    ] = Field(default=None, alias="ScaleDownBehavior")
1568    custom_ami_id: Optional[str] = Field(default=None, alias="CustomAmiId")
1569    ebs_root_volume_size: Optional[int] = Field(default=None, alias="EbsRootVolumeSize")
1570    repo_upgrade_on_boot: Optional[Literal["NONE", "SECURITY"]] = Field(
1571        default=None, alias="RepoUpgradeOnBoot"
1572    )
1573    kerberos_attributes: Optional[KerberosAttributesModel] = Field(
1574        default=None, alias="KerberosAttributes"
1575    )
1576    cluster_arn: Optional[str] = Field(default=None, alias="ClusterArn")
1577    outpost_arn: Optional[str] = Field(default=None, alias="OutpostArn")
1578    step_concurrency_level: Optional[int] = Field(
1579        default=None, alias="StepConcurrencyLevel"
1580    )
1581    placement_groups: Optional[List[PlacementGroupConfigModel]] = Field(
1582        default=None, alias="PlacementGroups"
1583    )
1584    os_release_label: Optional[str] = Field(default=None, alias="OSReleaseLabel")
1585
1586
1587class GetManagedScalingPolicyOutputModel(BaseModel):
1588    managed_scaling_policy: ManagedScalingPolicyModel = Field(
1589        alias="ManagedScalingPolicy"
1590    )
1591    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1592
1593
1594class PutManagedScalingPolicyInputRequestModel(BaseModel):
1595    cluster_id: str = Field(alias="ClusterId")
1596    managed_scaling_policy: ManagedScalingPolicyModel = Field(
1597        alias="ManagedScalingPolicy"
1598    )
1599
1600
1601class GetClusterSessionCredentialsOutputModel(BaseModel):
1602    credentials: CredentialsModel = Field(alias="Credentials")
1603    expires_at: datetime = Field(alias="ExpiresAt")
1604    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1605
1606
1607class EbsConfigurationModel(BaseModel):
1608    ebs_block_device_configs: Optional[Sequence[EbsBlockDeviceConfigModel]] = Field(
1609        default=None, alias="EbsBlockDeviceConfigs"
1610    )
1611    ebs_optimized: Optional[bool] = Field(default=None, alias="EbsOptimized")
1612
1613
1614class InstanceTypeSpecificationModel(BaseModel):
1615    instance_type: Optional[str] = Field(default=None, alias="InstanceType")
1616    weighted_capacity: Optional[int] = Field(default=None, alias="WeightedCapacity")
1617    bid_price: Optional[str] = Field(default=None, alias="BidPrice")
1618    bid_price_as_percentage_of_on_demand_price: Optional[float] = Field(
1619        default=None, alias="BidPriceAsPercentageOfOnDemandPrice"
1620    )
1621    configurations: Optional[List[ConfigurationModel]] = Field(
1622        default=None, alias="Configurations"
1623    )
1624    ebs_block_devices: Optional[List[EbsBlockDeviceModel]] = Field(
1625        default=None, alias="EbsBlockDevices"
1626    )
1627    ebs_optimized: Optional[bool] = Field(default=None, alias="EbsOptimized")
1628    custom_ami_id: Optional[str] = Field(default=None, alias="CustomAmiId")
1629
1630
1631class DescribeNotebookExecutionOutputModel(BaseModel):
1632    notebook_execution: NotebookExecutionModel = Field(alias="NotebookExecution")
1633    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1634
1635
1636class StepConfigModel(BaseModel):
1637    name: str = Field(alias="Name")
1638    hadoop_jar_step: HadoopJarStepConfigModel = Field(alias="HadoopJarStep")
1639    action_on_failure: Optional[
1640        Literal[
1641            "CANCEL_AND_WAIT", "CONTINUE", "TERMINATE_CLUSTER", "TERMINATE_JOB_FLOW"
1642        ]
1643    ] = Field(default=None, alias="ActionOnFailure")
1644
1645
1646class InstanceFleetModifyConfigModel(BaseModel):
1647    instance_fleet_id: str = Field(alias="InstanceFleetId")
1648    target_on_demand_capacity: Optional[int] = Field(
1649        default=None, alias="TargetOnDemandCapacity"
1650    )
1651    target_spot_capacity: Optional[int] = Field(
1652        default=None, alias="TargetSpotCapacity"
1653    )
1654    resize_specifications: Optional[InstanceFleetResizingSpecificationsModel] = Field(
1655        default=None, alias="ResizeSpecifications"
1656    )
1657
1658
1659class InstanceGroupModifyConfigModel(BaseModel):
1660    instance_group_id: str = Field(alias="InstanceGroupId")
1661    instance_count: Optional[int] = Field(default=None, alias="InstanceCount")
1662    ec2_instance_ids_to_terminate: Optional[Sequence[str]] = Field(
1663        default=None, alias="EC2InstanceIdsToTerminate"
1664    )
1665    shrink_policy: Optional[ShrinkPolicyModel] = Field(
1666        default=None, alias="ShrinkPolicy"
1667    )
1668    reconfiguration_type: Optional[Literal["MERGE", "OVERWRITE"]] = Field(
1669        default=None, alias="ReconfigurationType"
1670    )
1671    configurations: Optional[Sequence[ConfigurationModel]] = Field(
1672        default=None, alias="Configurations"
1673    )
1674
1675
1676class InstanceModel(BaseModel):
1677    id: Optional[str] = Field(default=None, alias="Id")
1678    ec2_instance_id: Optional[str] = Field(default=None, alias="Ec2InstanceId")
1679    public_dns_name: Optional[str] = Field(default=None, alias="PublicDnsName")
1680    public_ip_address: Optional[str] = Field(default=None, alias="PublicIpAddress")
1681    private_dns_name: Optional[str] = Field(default=None, alias="PrivateDnsName")
1682    private_ip_address: Optional[str] = Field(default=None, alias="PrivateIpAddress")
1683    status: Optional[InstanceStatusModel] = Field(default=None, alias="Status")
1684    instance_group_id: Optional[str] = Field(default=None, alias="InstanceGroupId")
1685    instance_fleet_id: Optional[str] = Field(default=None, alias="InstanceFleetId")
1686    market: Optional[Literal["ON_DEMAND", "SPOT"]] = Field(default=None, alias="Market")
1687    instance_type: Optional[str] = Field(default=None, alias="InstanceType")
1688    ebs_volumes: Optional[List[EbsVolumeModel]] = Field(
1689        default=None, alias="EbsVolumes"
1690    )
1691
1692
1693class InstanceFleetProvisioningSpecificationsModel(BaseModel):
1694    spot_specification: Optional[SpotProvisioningSpecificationModel] = Field(
1695        default=None, alias="SpotSpecification"
1696    )
1697    on_demand_specification: Optional[OnDemandProvisioningSpecificationModel] = Field(
1698        default=None, alias="OnDemandSpecification"
1699    )
1700
1701
1702class StepSummaryModel(BaseModel):
1703    id: Optional[str] = Field(default=None, alias="Id")
1704    name: Optional[str] = Field(default=None, alias="Name")
1705    config: Optional[HadoopStepConfigModel] = Field(default=None, alias="Config")
1706    action_on_failure: Optional[
1707        Literal[
1708            "CANCEL_AND_WAIT", "CONTINUE", "TERMINATE_CLUSTER", "TERMINATE_JOB_FLOW"
1709        ]
1710    ] = Field(default=None, alias="ActionOnFailure")
1711    status: Optional[StepStatusModel] = Field(default=None, alias="Status")
1712
1713
1714class StepModel(BaseModel):
1715    id: Optional[str] = Field(default=None, alias="Id")
1716    name: Optional[str] = Field(default=None, alias="Name")
1717    config: Optional[HadoopStepConfigModel] = Field(default=None, alias="Config")
1718    action_on_failure: Optional[
1719        Literal[
1720            "CANCEL_AND_WAIT", "CONTINUE", "TERMINATE_CLUSTER", "TERMINATE_JOB_FLOW"
1721        ]
1722    ] = Field(default=None, alias="ActionOnFailure")
1723    status: Optional[StepStatusModel] = Field(default=None, alias="Status")
1724    execution_role_arn: Optional[str] = Field(default=None, alias="ExecutionRoleArn")
1725
1726
1727class ScalingRuleModel(BaseModel):
1728    name: str = Field(alias="Name")
1729    action: ScalingActionModel = Field(alias="Action")
1730    trigger: ScalingTriggerModel = Field(alias="Trigger")
1731    description: Optional[str] = Field(default=None, alias="Description")
1732
1733
1734class ListClustersOutputModel(BaseModel):
1735    clusters: List[ClusterSummaryModel] = Field(alias="Clusters")
1736    marker: str = Field(alias="Marker")
1737    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1738
1739
1740class DescribeClusterOutputModel(BaseModel):
1741    cluster: ClusterModel = Field(alias="Cluster")
1742    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1743
1744
1745class InstanceTypeConfigModel(BaseModel):
1746    instance_type: str = Field(alias="InstanceType")
1747    weighted_capacity: Optional[int] = Field(default=None, alias="WeightedCapacity")
1748    bid_price: Optional[str] = Field(default=None, alias="BidPrice")
1749    bid_price_as_percentage_of_on_demand_price: Optional[float] = Field(
1750        default=None, alias="BidPriceAsPercentageOfOnDemandPrice"
1751    )
1752    ebs_configuration: Optional[EbsConfigurationModel] = Field(
1753        default=None, alias="EbsConfiguration"
1754    )
1755    configurations: Optional[Sequence[ConfigurationModel]] = Field(
1756        default=None, alias="Configurations"
1757    )
1758    custom_ami_id: Optional[str] = Field(default=None, alias="CustomAmiId")
1759
1760
1761class AddJobFlowStepsInputRequestModel(BaseModel):
1762    job_flow_id: str = Field(alias="JobFlowId")
1763    steps: Sequence[StepConfigModel] = Field(alias="Steps")
1764    execution_role_arn: Optional[str] = Field(default=None, alias="ExecutionRoleArn")
1765
1766
1767class StepDetailModel(BaseModel):
1768    step_config: StepConfigModel = Field(alias="StepConfig")
1769    execution_status_detail: StepExecutionStatusDetailModel = Field(
1770        alias="ExecutionStatusDetail"
1771    )
1772
1773
1774class ModifyInstanceFleetInputRequestModel(BaseModel):
1775    cluster_id: str = Field(alias="ClusterId")
1776    instance_fleet: InstanceFleetModifyConfigModel = Field(alias="InstanceFleet")
1777
1778
1779class ModifyInstanceGroupsInputRequestModel(BaseModel):
1780    cluster_id: Optional[str] = Field(default=None, alias="ClusterId")
1781    instance_groups: Optional[Sequence[InstanceGroupModifyConfigModel]] = Field(
1782        default=None, alias="InstanceGroups"
1783    )
1784
1785
1786class ListInstancesOutputModel(BaseModel):
1787    instances: List[InstanceModel] = Field(alias="Instances")
1788    marker: str = Field(alias="Marker")
1789    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1790
1791
1792class InstanceFleetModel(BaseModel):
1793    id: Optional[str] = Field(default=None, alias="Id")
1794    name: Optional[str] = Field(default=None, alias="Name")
1795    status: Optional[InstanceFleetStatusModel] = Field(default=None, alias="Status")
1796    instance_fleet_type: Optional[Literal["CORE", "MASTER", "TASK"]] = Field(
1797        default=None, alias="InstanceFleetType"
1798    )
1799    target_on_demand_capacity: Optional[int] = Field(
1800        default=None, alias="TargetOnDemandCapacity"
1801    )
1802    target_spot_capacity: Optional[int] = Field(
1803        default=None, alias="TargetSpotCapacity"
1804    )
1805    provisioned_on_demand_capacity: Optional[int] = Field(
1806        default=None, alias="ProvisionedOnDemandCapacity"
1807    )
1808    provisioned_spot_capacity: Optional[int] = Field(
1809        default=None, alias="ProvisionedSpotCapacity"
1810    )
1811    instance_type_specifications: Optional[
1812        List[InstanceTypeSpecificationModel]
1813    ] = Field(default=None, alias="InstanceTypeSpecifications")
1814    launch_specifications: Optional[
1815        InstanceFleetProvisioningSpecificationsModel
1816    ] = Field(default=None, alias="LaunchSpecifications")
1817    resize_specifications: Optional[InstanceFleetResizingSpecificationsModel] = Field(
1818        default=None, alias="ResizeSpecifications"
1819    )
1820
1821
1822class ListStepsOutputModel(BaseModel):
1823    steps: List[StepSummaryModel] = Field(alias="Steps")
1824    marker: str = Field(alias="Marker")
1825    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1826
1827
1828class DescribeStepOutputModel(BaseModel):
1829    step: StepModel = Field(alias="Step")
1830    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1831
1832
1833class AutoScalingPolicyDescriptionModel(BaseModel):
1834    status: Optional[AutoScalingPolicyStatusModel] = Field(default=None, alias="Status")
1835    constraints: Optional[ScalingConstraintsModel] = Field(
1836        default=None, alias="Constraints"
1837    )
1838    rules: Optional[List[ScalingRuleModel]] = Field(default=None, alias="Rules")
1839
1840
1841class AutoScalingPolicyModel(BaseModel):
1842    constraints: ScalingConstraintsModel = Field(alias="Constraints")
1843    rules: Sequence[ScalingRuleModel] = Field(alias="Rules")
1844
1845
1846class InstanceFleetConfigModel(BaseModel):
1847    instance_fleet_type: Literal["CORE", "MASTER", "TASK"] = Field(
1848        alias="InstanceFleetType"
1849    )
1850    name: Optional[str] = Field(default=None, alias="Name")
1851    target_on_demand_capacity: Optional[int] = Field(
1852        default=None, alias="TargetOnDemandCapacity"
1853    )
1854    target_spot_capacity: Optional[int] = Field(
1855        default=None, alias="TargetSpotCapacity"
1856    )
1857    instance_type_configs: Optional[Sequence[InstanceTypeConfigModel]] = Field(
1858        default=None, alias="InstanceTypeConfigs"
1859    )
1860    launch_specifications: Optional[
1861        InstanceFleetProvisioningSpecificationsModel
1862    ] = Field(default=None, alias="LaunchSpecifications")
1863    resize_specifications: Optional[InstanceFleetResizingSpecificationsModel] = Field(
1864        default=None, alias="ResizeSpecifications"
1865    )
1866
1867
1868class JobFlowDetailModel(BaseModel):
1869    job_flow_id: str = Field(alias="JobFlowId")
1870    name: str = Field(alias="Name")
1871    execution_status_detail: JobFlowExecutionStatusDetailModel = Field(
1872        alias="ExecutionStatusDetail"
1873    )
1874    instances: JobFlowInstancesDetailModel = Field(alias="Instances")
1875    log_uri: Optional[str] = Field(default=None, alias="LogUri")
1876    log_encryption_kms_key_id: Optional[str] = Field(
1877        default=None, alias="LogEncryptionKmsKeyId"
1878    )
1879    ami_version: Optional[str] = Field(default=None, alias="AmiVersion")
1880    steps: Optional[List[StepDetailModel]] = Field(default=None, alias="Steps")
1881    bootstrap_actions: Optional[List[BootstrapActionDetailModel]] = Field(
1882        default=None, alias="BootstrapActions"
1883    )
1884    supported_products: Optional[List[str]] = Field(
1885        default=None, alias="SupportedProducts"
1886    )
1887    visible_to_all_users: Optional[bool] = Field(
1888        default=None, alias="VisibleToAllUsers"
1889    )
1890    job_flow_role: Optional[str] = Field(default=None, alias="JobFlowRole")
1891    service_role: Optional[str] = Field(default=None, alias="ServiceRole")
1892    auto_scaling_role: Optional[str] = Field(default=None, alias="AutoScalingRole")
1893    scale_down_behavior: Optional[
1894        Literal["TERMINATE_AT_INSTANCE_HOUR", "TERMINATE_AT_TASK_COMPLETION"]
1895    ] = Field(default=None, alias="ScaleDownBehavior")
1896
1897
1898class ListInstanceFleetsOutputModel(BaseModel):
1899    instance_fleets: List[InstanceFleetModel] = Field(alias="InstanceFleets")
1900    marker: str = Field(alias="Marker")
1901    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1902
1903
1904class InstanceGroupModel(BaseModel):
1905    id: Optional[str] = Field(default=None, alias="Id")
1906    name: Optional[str] = Field(default=None, alias="Name")
1907    market: Optional[Literal["ON_DEMAND", "SPOT"]] = Field(default=None, alias="Market")
1908    instance_group_type: Optional[Literal["CORE", "MASTER", "TASK"]] = Field(
1909        default=None, alias="InstanceGroupType"
1910    )
1911    bid_price: Optional[str] = Field(default=None, alias="BidPrice")
1912    instance_type: Optional[str] = Field(default=None, alias="InstanceType")
1913    requested_instance_count: Optional[int] = Field(
1914        default=None, alias="RequestedInstanceCount"
1915    )
1916    running_instance_count: Optional[int] = Field(
1917        default=None, alias="RunningInstanceCount"
1918    )
1919    status: Optional[InstanceGroupStatusModel] = Field(default=None, alias="Status")
1920    configurations: Optional[List[ConfigurationModel]] = Field(
1921        default=None, alias="Configurations"
1922    )
1923    configurations_version: Optional[int] = Field(
1924        default=None, alias="ConfigurationsVersion"
1925    )
1926    last_successfully_applied_configurations: Optional[
1927        List[ConfigurationModel]
1928    ] = Field(default=None, alias="LastSuccessfullyAppliedConfigurations")
1929    last_successfully_applied_configurations_version: Optional[int] = Field(
1930        default=None, alias="LastSuccessfullyAppliedConfigurationsVersion"
1931    )
1932    ebs_block_devices: Optional[List[EbsBlockDeviceModel]] = Field(
1933        default=None, alias="EbsBlockDevices"
1934    )
1935    ebs_optimized: Optional[bool] = Field(default=None, alias="EbsOptimized")
1936    shrink_policy: Optional[ShrinkPolicyModel] = Field(
1937        default=None, alias="ShrinkPolicy"
1938    )
1939    auto_scaling_policy: Optional[AutoScalingPolicyDescriptionModel] = Field(
1940        default=None, alias="AutoScalingPolicy"
1941    )
1942    custom_ami_id: Optional[str] = Field(default=None, alias="CustomAmiId")
1943
1944
1945class PutAutoScalingPolicyOutputModel(BaseModel):
1946    cluster_id: str = Field(alias="ClusterId")
1947    instance_group_id: str = Field(alias="InstanceGroupId")
1948    auto_scaling_policy: AutoScalingPolicyDescriptionModel = Field(
1949        alias="AutoScalingPolicy"
1950    )
1951    cluster_arn: str = Field(alias="ClusterArn")
1952    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1953
1954
1955class InstanceGroupConfigModel(BaseModel):
1956    instance_role: Literal["CORE", "MASTER", "TASK"] = Field(alias="InstanceRole")
1957    instance_type: str = Field(alias="InstanceType")
1958    instance_count: int = Field(alias="InstanceCount")
1959    name: Optional[str] = Field(default=None, alias="Name")
1960    market: Optional[Literal["ON_DEMAND", "SPOT"]] = Field(default=None, alias="Market")
1961    bid_price: Optional[str] = Field(default=None, alias="BidPrice")
1962    configurations: Optional[Sequence[ConfigurationModel]] = Field(
1963        default=None, alias="Configurations"
1964    )
1965    ebs_configuration: Optional[EbsConfigurationModel] = Field(
1966        default=None, alias="EbsConfiguration"
1967    )
1968    auto_scaling_policy: Optional[AutoScalingPolicyModel] = Field(
1969        default=None, alias="AutoScalingPolicy"
1970    )
1971    custom_ami_id: Optional[str] = Field(default=None, alias="CustomAmiId")
1972
1973
1974class PutAutoScalingPolicyInputRequestModel(BaseModel):
1975    cluster_id: str = Field(alias="ClusterId")
1976    instance_group_id: str = Field(alias="InstanceGroupId")
1977    auto_scaling_policy: AutoScalingPolicyModel = Field(alias="AutoScalingPolicy")
1978
1979
1980class AddInstanceFleetInputRequestModel(BaseModel):
1981    cluster_id: str = Field(alias="ClusterId")
1982    instance_fleet: InstanceFleetConfigModel = Field(alias="InstanceFleet")
1983
1984
1985class DescribeJobFlowsOutputModel(BaseModel):
1986    job_flows: List[JobFlowDetailModel] = Field(alias="JobFlows")
1987    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1988
1989
1990class ListInstanceGroupsOutputModel(BaseModel):
1991    instance_groups: List[InstanceGroupModel] = Field(alias="InstanceGroups")
1992    marker: str = Field(alias="Marker")
1993    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1994
1995
1996class AddInstanceGroupsInputRequestModel(BaseModel):
1997    instance_groups: Sequence[InstanceGroupConfigModel] = Field(alias="InstanceGroups")
1998    job_flow_id: str = Field(alias="JobFlowId")
1999
2000
2001class JobFlowInstancesConfigModel(BaseModel):
2002    master_instance_type: Optional[str] = Field(
2003        default=None, alias="MasterInstanceType"
2004    )
2005    slave_instance_type: Optional[str] = Field(default=None, alias="SlaveInstanceType")
2006    instance_count: Optional[int] = Field(default=None, alias="InstanceCount")
2007    instance_groups: Optional[Sequence[InstanceGroupConfigModel]] = Field(
2008        default=None, alias="InstanceGroups"
2009    )
2010    instance_fleets: Optional[Sequence[InstanceFleetConfigModel]] = Field(
2011        default=None, alias="InstanceFleets"
2012    )
2013    ec2_key_name: Optional[str] = Field(default=None, alias="Ec2KeyName")
2014    placement: Optional[PlacementTypeModel] = Field(default=None, alias="Placement")
2015    keep_job_flow_alive_when_no_steps: Optional[bool] = Field(
2016        default=None, alias="KeepJobFlowAliveWhenNoSteps"
2017    )
2018    termination_protected: Optional[bool] = Field(
2019        default=None, alias="TerminationProtected"
2020    )
2021    hadoop_version: Optional[str] = Field(default=None, alias="HadoopVersion")
2022    ec2_subnet_id: Optional[str] = Field(default=None, alias="Ec2SubnetId")
2023    ec2_subnet_ids: Optional[Sequence[str]] = Field(default=None, alias="Ec2SubnetIds")
2024    emr_managed_master_security_group: Optional[str] = Field(
2025        default=None, alias="EmrManagedMasterSecurityGroup"
2026    )
2027    emr_managed_slave_security_group: Optional[str] = Field(
2028        default=None, alias="EmrManagedSlaveSecurityGroup"
2029    )
2030    service_access_security_group: Optional[str] = Field(
2031        default=None, alias="ServiceAccessSecurityGroup"
2032    )
2033    additional_master_security_groups: Optional[Sequence[str]] = Field(
2034        default=None, alias="AdditionalMasterSecurityGroups"
2035    )
2036    additional_slave_security_groups: Optional[Sequence[str]] = Field(
2037        default=None, alias="AdditionalSlaveSecurityGroups"
2038    )
2039
2040
2041class RunJobFlowInputRequestModel(BaseModel):
2042    name: str = Field(alias="Name")
2043    instances: JobFlowInstancesConfigModel = Field(alias="Instances")
2044    log_uri: Optional[str] = Field(default=None, alias="LogUri")
2045    log_encryption_kms_key_id: Optional[str] = Field(
2046        default=None, alias="LogEncryptionKmsKeyId"
2047    )
2048    additional_info: Optional[str] = Field(default=None, alias="AdditionalInfo")
2049    ami_version: Optional[str] = Field(default=None, alias="AmiVersion")
2050    release_label: Optional[str] = Field(default=None, alias="ReleaseLabel")
2051    steps: Optional[Sequence[StepConfigModel]] = Field(default=None, alias="Steps")
2052    bootstrap_actions: Optional[Sequence[BootstrapActionConfigModel]] = Field(
2053        default=None, alias="BootstrapActions"
2054    )
2055    supported_products: Optional[Sequence[str]] = Field(
2056        default=None, alias="SupportedProducts"
2057    )
2058    new_supported_products: Optional[Sequence[SupportedProductConfigModel]] = Field(
2059        default=None, alias="NewSupportedProducts"
2060    )
2061    applications: Optional[Sequence[ApplicationModel]] = Field(
2062        default=None, alias="Applications"
2063    )
2064    configurations: Optional[Sequence[ConfigurationModel]] = Field(
2065        default=None, alias="Configurations"
2066    )
2067    visible_to_all_users: Optional[bool] = Field(
2068        default=None, alias="VisibleToAllUsers"
2069    )
2070    job_flow_role: Optional[str] = Field(default=None, alias="JobFlowRole")
2071    service_role: Optional[str] = Field(default=None, alias="ServiceRole")
2072    tags: Optional[Sequence[TagModel]] = Field(default=None, alias="Tags")
2073    security_configuration: Optional[str] = Field(
2074        default=None, alias="SecurityConfiguration"
2075    )
2076    auto_scaling_role: Optional[str] = Field(default=None, alias="AutoScalingRole")
2077    scale_down_behavior: Optional[
2078        Literal["TERMINATE_AT_INSTANCE_HOUR", "TERMINATE_AT_TASK_COMPLETION"]
2079    ] = Field(default=None, alias="ScaleDownBehavior")
2080    custom_ami_id: Optional[str] = Field(default=None, alias="CustomAmiId")
2081    ebs_root_volume_size: Optional[int] = Field(default=None, alias="EbsRootVolumeSize")
2082    repo_upgrade_on_boot: Optional[Literal["NONE", "SECURITY"]] = Field(
2083        default=None, alias="RepoUpgradeOnBoot"
2084    )
2085    kerberos_attributes: Optional[KerberosAttributesModel] = Field(
2086        default=None, alias="KerberosAttributes"
2087    )
2088    step_concurrency_level: Optional[int] = Field(
2089        default=None, alias="StepConcurrencyLevel"
2090    )
2091    managed_scaling_policy: Optional[ManagedScalingPolicyModel] = Field(
2092        default=None, alias="ManagedScalingPolicy"
2093    )
2094    placement_group_configs: Optional[Sequence[PlacementGroupConfigModel]] = Field(
2095        default=None, alias="PlacementGroupConfigs"
2096    )
2097    auto_termination_policy: Optional[AutoTerminationPolicyModel] = Field(
2098        default=None, alias="AutoTerminationPolicy"
2099    )
2100    os_release_label: Optional[str] = Field(default=None, alias="OSReleaseLabel")