From 7faa96fa127e1f65b92e9b6fed3b69f77c14b355 Mon Sep 17 00:00:00 2001 From: Gunjan Chhablani Date: Tue, 11 Jul 2023 16:24:14 -0400 Subject: [PATCH] [Worker] Address missing job name in code upload worker (#4016) --- scripts/workers/code_upload_submission_worker.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/scripts/workers/code_upload_submission_worker.py b/scripts/workers/code_upload_submission_worker.py index 17a7ea852f..59e6c28026 100755 --- a/scripts/workers/code_upload_submission_worker.py +++ b/scripts/workers/code_upload_submission_worker.py @@ -749,8 +749,15 @@ def main(): ): try: # Fetch the last job name from the list as it is the latest running job - job_name = submission.get("job_name")[-1] - delete_job(api_instance, job_name) + job_name = submission.get("job_name") + if job_name: + latest_job_name = job_name[-1] + delete_job(api_instance, latest_job_name) + else: + logger.info( + "No job name found corresponding to submission: {} with status: {}." + "Deleting it from queue.".format(submission_pk, submission.get("status")) + ) message_receipt_handle = message.get("receipt_handle") evalai.delete_message_from_sqs_queue( message_receipt_handle