From 13c0f87fc69782a6ecbe3f90eda085e444c23762 Mon Sep 17 00:00:00 2001 From: faris Aljohari <83524184+farisaljohari@users.noreply.github.com> Date: Mon, 30 Jun 2025 04:09:40 -0600 Subject: [PATCH] fix: filter daily averages by space_id and event_date in update procedure --- .../proceduce_update_daily_space_aqi.sql | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql b/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql index 04fb661..46c1dd9 100644 --- a/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql +++ b/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql @@ -276,9 +276,11 @@ SELECT p.good_ch2o_percentage, p.moderate_ch2o_percentage, p.unhealthy_sensitive_ch2o_percentage, p.unhealthy_ch2o_percentage, p.very_unhealthy_ch2o_percentage, p.hazardous_ch2o_percentage, a.daily_avg_ch2o,a.daily_max_ch2o, a.daily_min_ch2o FROM daily_percentages p -LEFT JOIN daily_averages a - ON p.space_id = a.space_id AND p.event_date = a.event_date -ORDER BY p.space_id, p.event_date) + LEFT JOIN daily_averages a + ON p.space_id = a.space_id AND p.event_date = a.event_date + WHERE p.space_id = (SELECT space_id FROM params) + AND p.event_date = (SELECT event_date FROM params) + ORDER BY p.space_id, p.event_date) INSERT INTO public."space-daily-pollutant-stats" (