diff --git a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py index 4e08009..d9cf281 100644 --- 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"]