diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index 9057e92c2..60520c17c 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -138,7 +138,6 @@ def check_job_status(): # if they haven't been re-processed in time. job_ids = [] for job in jobs_not_complete_after_allotted_time: - job.job_status = JobStatus.ERROR dao_update_job_status_to_error(job) job_ids.append(str(job.id)) if job_ids: