darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-03 09:51:11 -05:00
Code Issues Packages Projects Releases Wiki Activity

try again

Browse Source
This commit is contained in:
Kenneth Kehl
2024-12-30 12:20:30 -08:00
parent 4e3f89906d
commit 71f682ae70
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
app/celery/scheduled_tasks.py
View File

@@ -131,13 +131,14 @@ def check_job_status():
) )
jobs_not_complete_after_allotted_time = ( 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 # 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. # if they haven't been re-processed in time.
job_ids = [] job_ids = []
for job in jobs_not_complete_after_allotted_time: for job in jobs_not_complete_after_allotted_time:
print(f"HERE IS A FREAKING JOB {job}")
dao_update_job_status_to_error(job) dao_update_job_status_to_error(job)
job_ids.append(str(job.id)) job_ids.append(str(job.id))
if job_ids: if job_ids: