chore: only set sensor to get results of 10 stations

JasperHG90 · Jan 25, 2024 · acf9d41 · acf9d41
1 parent 48e05a5
commit acf9d41
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py
@@ -52,7 +52,7 @@ def slack_message_on_failure(context: RunFailureSensorContext, slack: SlackResou
 @sensor(job=ingestion_job)
 def stations_sensor(context, luchtmeetnet_api: LuchtMeetNetResource):
     # Only take first three stations for demo purposes
-    stations_request = luchtmeetnet_api.request("stations")
+    stations_request = luchtmeetnet_api.request("stations")[:10]
     context.log.debug(stations_request)
     stations = [
         f["number"]