From acf23decdf1ffba228899ee64ba89db83db106da Mon Sep 17 00:00:00 2001 From: Bill Prin Date: Fri, 29 Apr 2016 15:45:47 -0700 Subject: [PATCH] Add more region tags --- dataproc/create_cluster_and_submit_job.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dataproc/create_cluster_and_submit_job.py b/dataproc/create_cluster_and_submit_job.py index e6b0c5a7379..9077f926c74 100644 --- a/dataproc/create_cluster_and_submit_job.py +++ b/dataproc/create_cluster_and_submit_job.py @@ -201,8 +201,10 @@ def main(project_id, zone, cluster_name, bucket_name, pyspark_file=None): (cluster_id, output_bucket) = ( get_cluster_id_by_name(cluster_list, cluster_name)) + # [START call_submit_pyspark_job] job_id = submit_pyspark_job( dataproc, project_id, cluster_name, bucket_name, spark_filename) + # [END call_submit_pyspark_job] wait_for_job(dataproc, project_id, job_id) output = download_output(project_id, cluster_id, output_bucket, job_id)