From acf9d4126587a3c36d0374ed7dd3cfb0ee7265b7 Mon Sep 17 00:00:00 2001 From: Jasper Ginn Date: Thu, 25 Jan 2024 22:03:39 +0100 Subject: [PATCH] chore: only set sensor to get results of 10 stations --- .../src/luchtmeetnet_ingestion/sensors.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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"]