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()