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