def create_cluster()

in awswrangler/emr.py [0:0]

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

def create_cluster(  # pylint: disable=too-many-arguments,too-many-locals,unused-argument
    subnet_id: str,
    cluster_name: str = "my-emr-cluster",
    logging_s3_path: Optional[str] = None,
    emr_release: str = "emr-6.0.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: Optional[List[str]] = None,
    debugging: bool = True,
    applications: Optional[List[str]] = None,
    visible_to_all_users: bool = True,
    key_pair_name: Optional[str] = None,
    security_group_master: Optional[str] = None,
    security_groups_master_additional: Optional[List[str]] = None,
    security_group_slave: Optional[str] = None,
    security_groups_slave_additional: Optional[List[str]] = None,
    security_group_service_access: Optional[str] = None,
    docker: bool = False,
    extra_public_registries: Optional[List[str]] = None,
    spark_log_level: str = "WARN",
    spark_jars_path: Optional[List[str]] = None,
    spark_defaults: Optional[Dict[str, str]] = None,
    spark_pyarrow: bool = False,
    custom_classifications: Optional[List[Dict[str, Any]]] = None,
    maximize_resource_allocation: bool = False,
    steps: Optional[List[Dict[str, Any]]] = None,
    custom_ami_id: Optional[str] = None,
    step_concurrency_level: int = 1,
    keep_cluster_alive_when_no_steps: bool = True,
    termination_protected: bool = False,
    tags: Optional[Dict[str, str]] = None,
    boto3_session: Optional[boto3.Session] = None,