This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-8-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit b88d0d7ce2944b5ed3c04d30fffcac37eaaa1859 Author: Andrey Anshin <andrey.ans...@taragol.is> AuthorDate: Mon Nov 20 19:55:30 2023 +0400 OpenLineage integration tried to use non-existed method in SnowflakeHook (#35752) --- airflow/providers/snowflake/hooks/snowflake.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/providers/snowflake/hooks/snowflake.py b/airflow/providers/snowflake/hooks/snowflake.py index f7f7a9a16f..081d734ac3 100644 --- a/airflow/providers/snowflake/hooks/snowflake.py +++ b/airflow/providers/snowflake/hooks/snowflake.py @@ -480,7 +480,7 @@ class SnowflakeHook(DbApiHook): from airflow.providers.openlineage.sqlparser import SQLParser connection = self.get_connection(getattr(self, self.conn_name_attr)) - namespace = SQLParser.create_namespace(self.get_database_info(connection)) + namespace = SQLParser.create_namespace(self.get_openlineage_database_info(connection)) if self.query_ids: return OperatorLineage(