def submit_job()

in scale_test_tool/helper/emr_container_helper.py [0:0]

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

def submit_job(client,
               job_name, client_token,
               entry_point, entry_point_arguments, spark_submit_params,
               virtual_cluster_id):
    response = client.start_job_run(
        name=job_name,
        virtualClusterId=virtual_cluster_id,
        clientToken=client_token,
        executionRoleArn=JOB_EXECUTION_ROLE_ARN,
        releaseLabel=RELEASE_LABEL,
        jobDriver={
            "sparkSubmitJobDriver": {
                "entryPoint": entry_point,
                "entryPointArguments": entry_point_arguments,
                "sparkSubmitParameters": spark_submit_params
            }
        },
        configurationOverrides={
            "monitoringConfiguration": {
                "cloudWatchMonitoringConfiguration": {
                    "logGroupName": CLOUD_WATCH_LOG_GROUP_NAME,
                    "logStreamNamePrefix": job_name
                },
                "s3MonitoringConfiguration": {
                    "logUri": S3_LOG_PATH
                }
            }
        }
    )
    return response