diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py
index 60520c17c..9e3d54004 100644
--- 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: