try again

GSA · Dec 30, 2024 · 71f682a · 71f682a
1 parent 4e3f899
commit 71f682a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py
@@ -131,13 +131,14 @@ def check_job_status():
     )
 
     jobs_not_complete_after_allotted_time = (
-        db.session.execute(jobs_not_completed_after_allotted_time).scalars().all()
+        db.session.execute(jobs_not_completed_after_allotted_time).all()
     )
 
     # temporarily mark them as ERROR so that they don't get picked up by future check_job_status tasks
     # if they haven't been re-processed in time.
     job_ids = []
     for job in jobs_not_complete_after_allotted_time:
+        print(f"HERE IS A FREAKING JOB {job}")
         dao_update_job_status_to_error(job)
         job_ids.append(str(job.id))
     if job_ids: