1bddafd3102e4e0841d78673581c3ead8f68a7c8,dataproc/submit_job_to_cluster.py,,wait_for_job,#Any#Any#Any#Any#,174

Before Change

def wait_for_job(dataproc, project, region, job_id):
    print("Waiting for job to finish...")
    while True:
        result = dataproc.projects().regions().jobs().get(
            projectId=project,
            region=region,
            jobId=job_id).execute()

After Change

    while True:
        job = dataproc.get_job(project, region, job_id)
        // Handle exceptions
        if job.status.State.Name(job.status.state) == "ERROR":
            raise Exception(job.status.details)
        elif job.status.State.Name(job.status.state) == "DONE":
            print("Job finished.")
            return job
// [END dataproc_wait]


def main(project_id,
         zone,
         cluster_name,
         bucket_name,

Instances