This is an automated email from the ASF dual-hosted git repository.
taragolis pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new f8dd192483 OpenLineage integration tried to use non-existed method in
SnowflakeHook (#35752)
f8dd192483 is described below
commit f8dd19248345ac259153812c68b65fc39accfcfd
Author: Andrey Anshin <[email protected]>
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(
