You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ep...@apache.org on 2023/11/23 07:28:44 UTC
(airflow) 04/37: OpenLineage integration tried to use non-existed method in SnowflakeHook (#35752)
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 <An...@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(