setop/agenda_culturel
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix bug au timeout

Browse Source
This commit is contained in:
Jean-Marie Favreau
2025-02-21 16:10:40 +01:00
parent d70650f6de
commit 5046f12bdc
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/agenda_culturel/celery.py
View File

@@ -66,10 +66,10 @@ def close_import_task(taskid, success, error_message, importer):
task.status = (
BatchImportation.STATUS.SUCCESS if success else BatchImportation.STATUS.FAILED
)
task.nb_initial = importer.get_nb_events()
task.nb_imported = importer.get_nb_imported_events()
task.nb_updated = importer.get_nb_updated_events()
task.nb_removed = importer.get_nb_removed_events()
task.nb_initial = 0 if importer is None else importer.get_nb_events()
task.nb_imported = 0 if importer is None else importer.get_nb_imported_events()
task.nb_updated = 0 if importer is None else importer.get_nb_updated_events()
task.nb_removed = 0 if importer is None else importer.get_nb_removed_events()
fields = ["status", "nb_initial", "nb_updated", "nb_imported", "nb_removed"]
if not success:
@@ -260,7 +260,7 @@ def run_recurrent_import(self, pklist):
raise self.retry(countdown=120)
except MaxRetriesExceededError as e:
logger.error(e)
close_import_task(self.request.id, False, e, importer)
close_import_task(self.request.id, False, e, None)
return pklist[1:] if is_list else False