Example dag: passed string value to pull func

cern-sis · Mar 11, 2024 · a2c90e6 · a2c90e6
1 parent ebcd3d6
commit a2c90e6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dags/example_dag/example_dag.py b/dags/example_dag/example_dag.py
@@ -15,7 +15,7 @@ def pull(test_string, **kwargs):
 @dag(
     start_date=pendulum.today("UTC").add(days=-1),
     schedule="@hourly",
-    params={"from_date": None, "until_date": None, "per_page": None},
+    params={},
 )
 def test_dag():
     @task()
@@ -26,7 +26,7 @@ def fetch_task(**kwargs):
     @task()
     def pull_task(test_string, **kwargs):
         logging.info(f"The value from previous task is: {test_string}")
-        return pull()
+        return pull(test_string)
 
     value = fetch_task()
     pull_task(value)