Improve example

apache · Oct 27, 2023 · 2e1cba6 · 2e1cba6
1 parent 836131d
commit 2e1cba6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/example_dags/tutorial_objectstorage.py b/airflow/example_dags/tutorial_objectstorage.py
@@ -70,10 +70,10 @@ def get_air_quality_data(**kwargs) -> ObjectStoragePath:
         """
         #### Get Air Quality Data
         This task gets air quality data from the Finnish Meteorological Institute's
-        open data API. The data is saved as json.
+        open data API. The data is saved as parquet.
         """
         execution_date = kwargs["logical_date"]
-        start_time = execution_date - pendulum.duration(days=1)
+        start_time = kwargs["data_interval_start"]
 
         params = {
             "format": "json",