diff --git a/airflow/providers/fab/auth_manager/security_manager/override.py b/airflow/providers/fab/auth_manager/security_manager/override.py index 56336b4fb2950..5040ad0b9b79b 100644 --- a/airflow/providers/fab/auth_manager/security_manager/override.py +++ b/airflow/providers/fab/auth_manager/security_manager/override.py @@ -1523,14 +1523,15 @@ def add_user( user.username = username user.email = email user.active = True + self.get_session.add(user) user.roles = role if isinstance(role, list) else [role] if hashed_password: user.password = hashed_password else: user.password = generate_password_hash(password) - self.get_session.add(user) self.get_session.commit() log.info(const.LOGMSG_INF_SEC_ADD_USER, username) + return user except Exception as e: log.error(const.LOGMSG_ERR_SEC_ADD_USER, e) diff --git a/airflow/providers/openlineage/utils/sql.py b/airflow/providers/openlineage/utils/sql.py index f5d083b4e4690..e29d8c6511c88 100644 --- a/airflow/providers/openlineage/utils/sql.py +++ b/airflow/providers/openlineage/utils/sql.py @@ -155,7 +155,7 @@ def create_information_schema_query( sqlalchemy_engine: Engine | None = None, ) -> str: """Create query for getting table schemas from information schema.""" - metadata = MetaData(sqlalchemy_engine) + metadata = MetaData() select_statements = [] # Don't iterate over tables hierarchy, just pass it to query single information schema table if use_flat_cross_db_query: