yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-07-25 02:04:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Modified snowflake view def query (#14994)

Browse Source
This commit is contained in:
Onkar Ravgan 2024-02-02 14:34:43 +05:30 committed by GitHub
parent 0d001c31d3
commit 131e5f5767
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ingestion/src/metadata/ingestion/source/database/snowflake/utils.py
View File

@ -120,13 +120,10 @@ def get_view_definition( # pylint: disable=unused-argument
schema = schema or self.default_schema_name schema = schema or self.default_schema_name
if schema: if schema:
cursor = connection.execute( cursor = connection.execute(
"SHOW /* sqlalchemy:get_view_definition */ VIEWS " f"SELECT GET_DDL('VIEW','{schema}.{view_name}') AS \"text\""
f"LIKE '{view_name}' IN {schema}"
) )
else: else:
cursor = connection.execute( cursor = connection.execute(f"SELECT GET_DDL('VIEW','{view_name}') AS \"text\"")
"SHOW /* sqlalchemy:get_view_definition */ VIEWS " f"LIKE '{view_name}'"
)
n2i = self.__class__._map_name_to_idx(cursor) # pylint: disable=protected-access n2i = self.__class__._map_name_to_idx(cursor) # pylint: disable=protected-access
try: try:
ret = cursor.fetchone() ret = cursor.fetchone()