From 204565118b5b8a86df8a2725299ed1d46882f138 Mon Sep 17 00:00:00 2001 From: Rik Veenboer Date: Wed, 29 Oct 2025 11:17:12 +0100 Subject: [PATCH] run request for 3 new locations --- apps/weather/src/sensors.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/apps/weather/src/sensors.py b/apps/weather/src/sensors.py index 37b7dde..3599759 100644 --- a/apps/weather/src/sensors.py +++ b/apps/weather/src/sensors.py @@ -39,9 +39,10 @@ def list_locations(context: dg.SensorEvaluationContext) -> dg.SensorResult: if new_locations: context.log.info(f"Discovered {len(new_locations)} new locations.") - # Limit to 3 new locations return dg.SensorResult( - run_requests=[], + run_requests=[ + dg.RunRequest(partition_key=location) for location in new_locations[:3] + ], dynamic_partitions_requests=[ location_partitions_def.build_add_request(new_locations), latitude_partitions_def.build_add_request(new_latitudes),