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

open-metadata · Nov 20, 2023 · 9fe4a2f · 9fe4a2f
1 parent e2b081d
commit 9fe4a2f
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 3 deletions.
diff --git a/ingestion/src/metadata/ingestion/source/database/snowflake/metadata.py b/ingestion/src/metadata/ingestion/source/database/snowflake/metadata.py
@@ -591,7 +591,6 @@ def get_stored_procedure_queries_dict(self) -> Dict[str, List[QueryByProcedure]]
         start, _ = get_start_and_end(self.source_config.queryLogDuration)
         query = SNOWFLAKE_GET_STORED_PROCEDURE_QUERIES.format(
             start_date=start,
-            warehouse=self.service_connection.warehouse,
         )
 
         queries_dict = self.procedure_queries_dict(

diff --git a/ingestion/src/metadata/ingestion/source/database/snowflake/queries.py b/ingestion/src/metadata/ingestion/source/database/snowflake/queries.py
@@ -189,7 +189,6 @@
     FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_HISTORY SP
     WHERE QUERY_TYPE = 'CALL'
       AND START_TIME >= '{start_date}' 
-      AND WAREHOUSE_NAME = '{warehouse}'
 ),
 Q_HISTORY AS (
     SELECT
@@ -208,7 +207,6 @@
       AND QUERY_TEXT NOT LIKE '/* {{"app": "OpenMetadata", %%}} */%%'
       AND QUERY_TEXT NOT LIKE '/* {{"app": "dbt", %%}} */%%'
       AND START_TIME >= '{start_date}' 
-      AND WAREHOUSE_NAME = '{warehouse}'
 )
 SELECT
   SP.QUERY_ID AS PROCEDURE_ID,