From b62f97f27b10f0a67903fe438baa5dca7e199fe6 Mon Sep 17 00:00:00 2001 From: Teddy Date: Wed, 8 Feb 2023 15:53:43 +0100 Subject: [PATCH] fix(profiler): imporve logic for snowflake to pick up DML ran on different WH (#10150) --- ingestion/src/metadata/orm_profiler/metrics/system/system.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/ingestion/src/metadata/orm_profiler/metrics/system/system.py b/ingestion/src/metadata/orm_profiler/metrics/system/system.py index fadbac87de5..e665cfa6ce0 100644 --- a/ingestion/src/metadata/orm_profiler/metrics/system/system.py +++ b/ingestion/src/metadata/orm_profiler/metrics/system/system.py @@ -322,8 +322,7 @@ def _( metric_results: List[Dict] = [] information_schema_query_history = """ - SELECT * FROM table(information_schema.query_history_by_warehouse( - warehouse_name=>CURRENT_WAREHOUSE(), + SELECT * FROM table(information_schema.query_history( end_time_range_start=>to_timestamp_ltz(DATEADD(HOUR, -{decrement_start}, CURRENT_TIMESTAMP())), end_time_range_end=>to_timestamp_ltz(DATEADD(HOUR, -{decrement_end}, CURRENT_TIMESTAMP())), result_limit=>10000