a93d550: (HEAD, twitter/1.10+twtr) [TWTR][[AIRFLOW-4939]] Add Default…

… Retries and fix a small DAG refresh bug (twitter-forks#3) (2 weeks ago)
vshshjn7 · Aug 28, 2019 · bb31c65 · bb31c65
1 parent 6b339af
commit bb31c65
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/airflow/models/dagbag.py b/airflow/models/dagbag.py
@@ -134,8 +134,10 @@ def get_dag(self, dag_id):
                 )
         ):
             # Reprocess source file
+            # TODO: remove the below hack to find relative dag location in webserver
+            filepath = dag.fileloc if dag else orm_dag.fileloc
             found_dags = self.process_file(
-                filepath=correct_maybe_zipped(orm_dag.fileloc), only_if_updated=False)
+                filepath=correct_maybe_zipped(filepath), only_if_updated=False)
 
             # If the source file no longer exports `dag_id`, delete it from self.dags
             if found_dags and dag_id in [found_dag.dag_id for found_dag in found_dags]: