diff --git a/ingestion/src/metadata/ingestion/source/database/snowflake/metadata.py b/ingestion/src/metadata/ingestion/source/database/snowflake/metadata.py index b65542cf1d9a..9d607c0e51d7 100644 --- 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 index 4dd000b7e9c1..7eabcd5785a8 100644 --- 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,