Repository: incubator-airflow Updated Branches: refs/heads/master 387f08cd0 -> 01b3291cc
[AIRFLOW-178] Fix bug so that zip file is detected in DAG folder Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/50f911cd Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/50f911cd Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/50f911cd Branch: refs/heads/master Commit: 50f911cd39e9fd9abf3a1d3283cf2e6307ab2540 Parents: 456dada Author: Joy Gao <[email protected]> Authored: Wed May 25 21:10:14 2016 -0700 Committer: Joy Gao <[email protected]> Committed: Wed May 25 22:18:35 2016 -0700 ---------------------------------------------------------------------- airflow/models.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/50f911cd/airflow/models.py ---------------------------------------------------------------------- diff --git a/airflow/models.py b/airflow/models.py index 67958f2..b23e1ea 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -406,7 +406,7 @@ class DagBag(LoggingMixin): continue mod_name, file_ext = os.path.splitext( os.path.split(filepath)[-1]) - if file_ext != '.py': + if file_ext != '.py' and not zipfile.is_zipfile(filepath): continue if not any( [re.findall(p, filepath) for p in patterns]):
