diff --git a/providers/fab/src/airflow/providers/fab/auth_manager/security_manager/override.py b/providers/fab/src/airflow/providers/fab/auth_manager/security_manager/override.py index 4a97b5d1043e1..4c7897093ca1d 100644 --- a/providers/fab/src/airflow/providers/fab/auth_manager/security_manager/override.py +++ b/providers/fab/src/airflow/providers/fab/auth_manager/security_manager/override.py @@ -1457,11 +1457,19 @@ def find_user(self, username=None, email=None) -> User | None: ).one_or_none() except MultipleResultsFound: log.error("Multiple results found for user %s", username) + except Exception as e: + log.error("Error finding user %s: %s", username, e) + self.session.rollback() + return None elif email: try: return self.session.scalars(select(self.user_model).filter_by(email=email)).one_or_none() except MultipleResultsFound: log.error("Multiple results found for user with email %s", email) + except Exception as e: + log.error("Error finding user with email %s: %s", email, e) + self.session.rollback() + return None return None def update_user(self, user: User) -> bool: