1bddafd3102e4e0841d78673581c3ead8f68a7c8,dataproc/submit_job_to_cluster.py,,wait_for_cluster_creation,#,98

Before Change

            projectId=project_id,
            region=region).execute()
        cluster_list = result["clusters"]
        cluster = [c
                   for c in cluster_list
                   if c["clusterName"] == cluster_name][0]
        if cluster["status"]["state"] == "ERROR":
            raise Exception(result["status"]["details"])
        if cluster["status"]["state"] == "RUNNING":
            print("Cluster created.")

After Change

    Wait for cluster creation.
    print("Waiting for cluster creation...")

    while True:
        if not waiting_callback:
            print("Cluster created.")
            break


// [START dataproc_list_clusters_with_detail]
def list_clusters_with_details(dataproc, project, region):
    List the details of clusters in the region.
    for cluster in dataproc.list_clusters(project, region):
        print(("{} - {}".format(cluster.cluster_name,

Instances