Experiment API path fix (#37)

Co-authored-by: Vishesh Jain <visheshj@twitter.com>
twitter-forks · Apr 9, 2020 · f7050fb · f7050fb
1 parent 28b1c3d
commit f7050fb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/api/common/experimental/trigger_dag.py b/airflow/api/common/experimental/trigger_dag.py
@@ -114,7 +114,7 @@ def trigger_dag(
     dag_model = DagModel.get_current(dag_id)
     if dag_model is None:
         raise DagNotFound("Dag id {} not found in DagModel".format(dag_id))
-    dagbag = DagBag(dag_folder=dag_model.fileloc)
+    dagbag = DagBag(dag_folder=dag_model.get_local_fileloc())
     dag_run = DagRun()
     triggers = _trigger_dag(
         dag_id=dag_id,