darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-07-06 17:37:06 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1220 from GSA/main

Browse Source 
7/29/2024 Production Deploy for logging improvements
This commit is contained in:
Carlo Costino
2024-07-29 11:30:29 -04:00
committed by GitHub
parent d6d4358ef6 37bf12dc0c
commit 22170100a1
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
app/celery/nightly_tasks.py
View File

@@ -51,7 +51,13 @@ def cleanup_unfinished_jobs():
for job in jobs:
# The query already checks that the processing_finished time is null, so here we are saying
# if it started more than 4 hours ago, that's too long
acceptable_finish_time = job.processing_started + timedelta(minutes=5)
try:
acceptable_finish_time = job.processing_started + timedelta(minutes=5)
except TypeError:
current_app.logger.error(
f"Job ID {job.id} processing_started is {job.processing_started}."
)
raise
if now > acceptable_finish_time:
remove_csv_object(job.original_file_name)
dao_archive_job(job)