Merge pull request #3 from cern-sis/call-function

call function

dags/example_dag/example_dag.py

@@ -25,7 +25,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()
 
     value = fetch_task()
     pull_task(value)