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

Before Change

            region=region,
            jobId=job_id).execute()
        // Handle exceptions
        if result["status"]["state"] == "ERROR":
            raise Exception(result["status"]["details"])
        elif result["status"]["state"] == "DONE":
            print("Job finished.")
            return result
// [END dataproc_wait]


// [START dataproc_get_client]
def get_client():
    Builds an http client authenticated with the service account
    credentials.
    dataproc = googleapiclient.discovery.build("dataproc", "v1")

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