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(
