Update submit_spark_job_to_driver_node_group_cluster.py

aman-ebay · web-flow · commit 00527326cff7 · 2025-06-12T11:03:34.000-07:00
diff --git a/dataproc/snippets/submit_spark_job_to_driver_node_group_cluster.py b/dataproc/snippets/submit_spark_job_to_driver_node_group_cluster.py
@@ -65,7 +65,7 @@ def submit_job(project_id: str, region: str, cluster_name: str) -> None:
             request={"project_id": project_id, "region": region, "job": job}
         )
 
-        try: 
+        try:
             response = operation.result()
         except Exception as e:
             print(f"Error submitting job or waiting for completion: {e}")

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ def submit_job(project_id: str, region: str, cluster_name: str) -> None:`
`65`	`65`	`request={"project_id": project_id, "region": region, "job": job}`
`66`	`66`	`)`
`67`	`67`
`68`		`- try:`
	`68`	`+ try:`
`69`	`69`	`response = operation.result()`
`70`	`70`	`except Exception as e:`
`71`	`71`	`print(f"Error submitting job or waiting for completion: {e}")`