Skip to content

Commit cd6dc62

Browse files
medbparthea
andauthored
chore(samples): fix job polling (#314)
* Fix job polling * Update submit_job_to_cluster.py Co-authored-by: Anthonios Partheniou <[email protected]>
1 parent e56230f commit cd6dc62

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

dataproc/snippets/submit_job_to_cluster.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -202,9 +202,9 @@ def wait_for_job(dataproc, project, region, job_id):
202202
request={"project_id": project, "region": region, "job_id": job_id}
203203
)
204204
# Handle exceptions
205-
if job.status.State.Name(job.status.state) == "ERROR":
205+
if job.status.State(job.status.state).name == "ERROR":
206206
raise Exception(job.status.details)
207-
elif job.status.State.Name(job.status.state) == "DONE":
207+
if job.status.State(job.status.state).name == "DONE":
208208
print("Job finished.")
209209
return job
210210

0 commit comments

Comments
 (0)