You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/12/22 13:02:29 UTC
incubator-airflow git commit: [AIRFLOW-1904] Correct DAG fileloc to
the right filepath
Repository: incubator-airflow
Updated Branches:
refs/heads/master e6d316632 -> 1c8972df4
[AIRFLOW-1904] Correct DAG fileloc to the right filepath
Closes #2863 from jgao54/fix-fileloc
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/1c8972df
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/1c8972df
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/1c8972df
Branch: refs/heads/master
Commit: 1c8972df42d824e5a740c56b302f71158e7224d8
Parents: e6d3166
Author: Joy Gao <jo...@wepay.com>
Authored: Fri Dec 22 14:02:24 2017 +0100
Committer: Bolke de Bruin <bo...@xs4all.nl>
Committed: Fri Dec 22 14:02:24 2017 +0100
----------------------------------------------------------------------
airflow/models.py | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/1c8972df/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index b2f3bac..ec41b50 100755
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -329,6 +329,8 @@ class DagBag(BaseDagBag, LoggingMixin):
if isinstance(dag, DAG):
if not dag.full_filepath:
dag.full_filepath = filepath
+ if dag.fileloc != filepath:
+ dag.fileloc = filepath
dag.is_subdag = False
self.bag_dag(dag, parent_dag=dag, root_dag=dag)
found_dags.append(dag)