Skip to content

Commit 8b1a438

Browse files
authored
Update submit_spark_job_to_driver_node_group_cluster.py
1 parent 39ef77d commit 8b1a438

1 file changed

Lines changed: 1 addition & 5 deletions

File tree

dataproc/snippets/submit_spark_job_to_driver_node_group_cluster.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -65,11 +65,7 @@ def submit_job(project_id: str, region: str, cluster_name: str) -> None:
6565
request={"project_id": project_id, "region": region, "job": job}
6666
)
6767

68-
try:
69-
response = operation.result()
70-
except Exception as e:
71-
print(f"Error submitting job or waiting for completion: {e}")
72-
raise
68+
response = operation.result()
7369

7470
# Dataproc job output gets saved to the Cloud Storage bucket
7571
# allocated to the job. Use a regex to obtain the bucket and blob info.

0 commit comments

Comments
 (0)