def create_cluster()

in awswrangler/emr.py [0:0]

• 64 lines of code
• 1 McCabe index (conditional complexity)

def create_cluster(  # noqa: PLR0913
    subnet_id: str,
    cluster_name: str = "my-emr-cluster",
    logging_s3_path: str | None = None,
    emr_release: str = "emr-6.7.0",
    emr_ec2_role: str = "EMR_EC2_DefaultRole",
    emr_role: str = "EMR_DefaultRole",
    instance_type_master: str = "r5.xlarge",
    instance_type_core: str = "r5.xlarge",
    instance_type_task: str = "r5.xlarge",
    instance_ebs_size_master: int = 64,
    instance_ebs_size_core: int = 64,
    instance_ebs_size_task: int = 64,
    instance_num_on_demand_master: int = 1,
    instance_num_on_demand_core: int = 0,
    instance_num_on_demand_task: int = 0,
    instance_num_spot_master: int = 0,
    instance_num_spot_core: int = 0,
    instance_num_spot_task: int = 0,
    spot_bid_percentage_of_on_demand_master: int = 100,
    spot_bid_percentage_of_on_demand_core: int = 100,
    spot_bid_percentage_of_on_demand_task: int = 100,
    spot_provisioning_timeout_master: int = 5,
    spot_provisioning_timeout_core: int = 5,
    spot_provisioning_timeout_task: int = 5,
    spot_timeout_to_on_demand_master: bool = True,
    spot_timeout_to_on_demand_core: bool = True,
    spot_timeout_to_on_demand_task: bool = True,
    python3: bool = True,
    spark_glue_catalog: bool = True,
    hive_glue_catalog: bool = True,
    presto_glue_catalog: bool = True,
    consistent_view: bool = False,
    consistent_view_retry_seconds: int = 10,
    consistent_view_retry_count: int = 5,
    consistent_view_table_name: str = "EmrFSMetadata",
    bootstraps_paths: list[str] | None = None,
    debugging: bool = True,
    applications: list[str] | None = None,
    visible_to_all_users: bool = True,
    key_pair_name: str | None = None,
    security_group_master: str | None = None,
    security_groups_master_additional: list[str] | None = None,
    security_group_slave: str | None = None,
    security_groups_slave_additional: list[str] | None = None,
    security_group_service_access: str | None = None,
    security_configuration: str | None = None,
    docker: bool = False,
    extra_public_registries: list[str] | None = None,
    spark_log_level: str = "WARN",
    spark_jars_path: list[str] | None = None,
    spark_defaults: dict[str, str] | None = None,
    spark_pyarrow: bool = False,
    custom_classifications: list[dict[str, Any]] | None = None,
    maximize_resource_allocation: bool = False,
    steps: list[dict[str, Any]] | None = None,
    custom_ami_id: str | None = None,
    step_concurrency_level: int = 1,
    keep_cluster_alive_when_no_steps: bool = True,
    termination_protected: bool = False,
    auto_termination_policy: dict[str, int] | None = None,
    tags: dict[str, str] | None = None,
    boto3_session: boto3.Session | None = None,
    configurations: list[dict[str, Any]] | None = None,