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

log message

Browse Source
This commit is contained in:
msramalho
2024-06-12 12:31:10 +01:00
parent aa11c3f87a
commit 3e91369f65
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/worker.py
View File

@@ -32,10 +32,10 @@ def get_db():
@celery.task(name="create_archive_task", bind=True, autoretry_for=(Exception,), retry_backoff=True, retry_kwargs={'max_retries': 3}) @celery.task(name="create_archive_task", bind=True, autoretry_for=(Exception,), retry_backoff=True, retry_kwargs={'max_retries': 3})
def create_archive_task(self, archive_json: str): def create_archive_task(self, archive_json: str):
archive = schemas.ArchiveCreate.parse_raw(archive_json) archive = schemas.ArchiveCreate.parse_raw(archive_json)
logger.info(f"Archiving {archive.url=} {archive.tags=} {archive.public=} {archive.group_id=} {archive.author_id=}")
invalid = is_group_invalid_for_user(archive.public, archive.group_id, archive.author_id) invalid = is_group_invalid_for_user(archive.public, archive.group_id, archive.author_id)
if (invalid): if invalid:
raise Exception(invalid) # marks task FAILED, saves the Exception as reult raise Exception(invalid) # marks task FAILED, saves the Exception as result
url = archive.url url = archive.url
logger.info(f"{url=} {archive=}") logger.info(f"{url=} {archive=}")