Skip to content

Commit

Permalink
chore: correct region tag in submit_job_to_cluster.py (#304)
Browse files Browse the repository at this point in the history
Change region tag to make it unique. The previous tag was used in another create cluster file and caused problems with automation tools.
  • Loading branch information
aman-ebay committed Nov 12, 2021
1 parent 101a440 commit 007a381
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dataproc/snippets/submit_job_to_cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ def download_output(project, cluster_id, output_bucket, job_id):
return bucket.blob(output_blob).download_as_string()


# [START dataproc_create_cluster]
# [START dataproc_submit_job_create_cluster]
def create_cluster(dataproc, project, zone, region, cluster_name):
"""Create the cluster."""
print("Creating cluster...")
Expand All @@ -110,7 +110,7 @@ def create_cluster(dataproc, project, zone, region, cluster_name):
waiting_callback = True


# [END dataproc_create_cluster]
# [END dataproc_submit_job_create_cluster]


def callback(operation_future):
Expand Down

0 comments on commit 007a381

Please sign in to comment.