potiuk commented on code in PR #40078:
URL: https://github.com/apache/airflow/pull/40078#discussion_r1635230822
##########
airflow/providers/snowflake/hooks/snowflake.py:
##########
@@ -473,10 +473,10 @@ def get_openlineage_database_specific_lineage(self, _) ->
OperatorLineage | None
from airflow.providers.openlineage.extractors import OperatorLineage
from airflow.providers.openlineage.sqlparser import SQLParser
- connection = self.get_connection(getattr(self, self.conn_name_attr))
- namespace =
SQLParser.create_namespace(self.get_openlineage_database_info(connection))
-
if self.query_ids:
+ self.log.info("Getting connector to get database info :sadge:")
Review Comment:
That one also seem to be loosely related to fork case, possibly just
splitting the PR a bit should help.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
