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), ],