bellingcat/auto-archiver-api
1
0
Fork 0
mirror of https://github.com/bellingcat/auto-archiver-api.git synced 2026-06-08 03:28:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

ads extra try/catch to prevent upstream AA uncaught errors

Browse Source
This commit is contained in:
msramalho
2026-04-23 14:16:27 +01:00
parent 754e325302
commit faec932ef7
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
app/worker/main.py
View File

@@ -128,7 +128,21 @@ def create_sheet_task(self, sheet_json: str):
) )
orchestrator = ArchivingOrchestrator() orchestrator = ArchivingOrchestrator()
orchestrator.logger_id = AA_LOGGER_ID # ensure single logger orchestrator.logger_id = AA_LOGGER_ID # ensure single logger
orchestrator.setup(args) try:
orchestrator.setup(args)
except SystemExit as e:
log_error(e, "create_sheet_task: SystemExit from AA during setup")
cleanup_orchestrator(orchestrator)
return schemas.CelerySheetTask(
success=False,
sheet_id=sheet.sheet_id,
time=datetime.datetime.now().isoformat(),
stats={"archived": 0, "failed": 0, "errors": [str(e)]},
).model_dump()
except Exception as e:
log_error(e, "create_sheet_task: error during orchestrator setup")
cleanup_orchestrator(orchestrator)
raise
AA_LOGGER_ID = orchestrator.logger_id AA_LOGGER_ID = orchestrator.logger_id
stats = {"archived": 0, "failed": 0, "errors": []} stats = {"archived": 0, "failed": 0, "errors": []}