From 678b80379c73e587869bf634789af8e225d6b7c3 Mon Sep 17 00:00:00 2001 From: Saksham Date: Mon, 13 Apr 2026 10:56:49 +0200 Subject: [PATCH] fix(tasks): Add exception handling and logging for errors --- site/cds_rdm/tasks.py | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/site/cds_rdm/tasks.py b/site/cds_rdm/tasks.py index 8006d87a..a0b5d28a 100644 --- a/site/cds_rdm/tasks.py +++ b/site/cds_rdm/tasks.py @@ -32,15 +32,23 @@ @shared_task def sync_users(since=None, **kwargs): """Task to sync users with CERN database.""" - user_ids = users_sync(identities=dict(since=since)) - reindex_users.delay(user_ids) + try: + user_ids = users_sync(identities=dict(since=since)) + reindex_users.delay(user_ids) + except Exception as e: + db.session.rollback() + current_app.logger.exception(e) @shared_task def sync_groups(since=None, **kwargs): """Task to sync groups with CERN database.""" - group_ids = groups_sync(groups=dict(since=since)) - reindex_groups.delay(group_ids) + try: + group_ids = groups_sync(groups=dict(since=since)) + reindex_groups.delay(group_ids) + except Exception as e: + db.session.rollback() + current_app.logger.exception(e) @shared_task()