Skip to content

Commit

Permalink
more
Browse files Browse the repository at this point in the history
  • Loading branch information
ranchodeluxe committed May 9, 2024
1 parent f5749da commit 1a5dcdb
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion .github/workflows/submit_spark_job.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,9 @@

@retry(wait=wait_exponential(multiplier=1, max=60), stop=stop_after_delay(300))
def block_on_app_state(application_id):
resp = json.loads(client.get_application(applicationId=application_id))
resp = client.get_application(applicationId=application_id)
if resp.get('application').get('state') != 'STARTED':
print("retrying...")
raise Exception("retrying...")
else:
print("Application has started and we can submit the job now")
Expand Down

0 comments on commit 1a5dcdb

Please sign in to comment.