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

Snowflake SP don't filter by warehouse (#14018)

Browse Source
This commit is contained in:
Pere Miquel Brull 2023-11-17 14:18:15 +01:00 committed by GitHub
parent f847c1cf10
commit a8a1fd26b1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ingestion/src/metadata/ingestion/source/database/snowflake/metadata.py
View File

@ -591,7 +591,6 @@ class SnowflakeSource(
start, _ = get_start_and_end(self.source_config.queryLogDuration) start, _ = get_start_and_end(self.source_config.queryLogDuration)
query = SNOWFLAKE_GET_STORED_PROCEDURE_QUERIES.format( query = SNOWFLAKE_GET_STORED_PROCEDURE_QUERIES.format(
start_date=start, start_date=start,
warehouse=self.service_connection.warehouse,
) )
queries_dict = self.procedure_queries_dict( queries_dict = self.procedure_queries_dict(

2
ingestion/src/metadata/ingestion/source/database/snowflake/queries.py
View File

@ -189,7 +189,6 @@ WITH SP_HISTORY AS (
FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_HISTORY SP FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_HISTORY SP
WHERE QUERY_TYPE = 'CALL' WHERE QUERY_TYPE = 'CALL'
AND START_TIME >= '{start_date}' AND START_TIME >= '{start_date}'
AND WAREHOUSE_NAME = '{warehouse}'
), ),
Q_HISTORY AS ( Q_HISTORY AS (
SELECT SELECT
@ -208,7 +207,6 @@ Q_HISTORY AS (
AND QUERY_TEXT NOT LIKE '/* {{"app": "OpenMetadata", %%}} */%%' AND QUERY_TEXT NOT LIKE '/* {{"app": "OpenMetadata", %%}} */%%'
AND QUERY_TEXT NOT LIKE '/* {{"app": "dbt", %%}} */%%' AND QUERY_TEXT NOT LIKE '/* {{"app": "dbt", %%}} */%%'
AND START_TIME >= '{start_date}' AND START_TIME >= '{start_date}'
AND WAREHOUSE_NAME = '{warehouse}'
) )
SELECT SELECT
SP.QUERY_ID AS PROCEDURE_ID, SP.QUERY_ID AS PROCEDURE_ID,