diff --git a/birb_scheduler/run_scheduler.py b/birb_scheduler/run_scheduler.py index e265c56..9ad7151 100644 --- a/birb_scheduler/run_scheduler.py +++ b/birb_scheduler/run_scheduler.py @@ -26,7 +26,7 @@ def run(redis_client: Redis, site_url_map: Dict[str, str]): # Figuring out if any of the sites need attention incraising_queue_at = [] - for site_name, site_stat in weather_report: + for site_name, site_stat in weather_report.items(): if site_stat['queue']['derivative'] > 0.001 and site_stat['queue']['mean'] > 2: key = f"INCRAISINGQUEUE:{site_name}" incraising_queue_detected_times = redis_client.incr(key)