diff --git a/.github/workflows/submit_spark_job.py b/.github/workflows/submit_spark_job.py index d951296..82bc219 100644 --- a/.github/workflows/submit_spark_job.py +++ b/.github/workflows/submit_spark_job.py @@ -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")