From 71f682ae70b863cfc47091be84419c8785f25ac9 Mon Sep 17 00:00:00 2001 From: Kenneth Kehl <@kkehl@flexion.us> Date: Mon, 30 Dec 2024 12:20:30 -0800 Subject: [PATCH] try again --- app/celery/scheduled_tasks.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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: