You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by cr...@apache.org on 2017/09/27 17:09:46 UTC

incubator-airflow git commit: [AIRFLOW-1587] Fix CeleryExecutor import error

Repository: incubator-airflow
Updated Branches:
  refs/heads/master 034b7ede9 -> dca9ab3f8


[AIRFLOW-1587] Fix CeleryExecutor import error

`CeleryExcutor` can not import directly from
`airflow.executors`, we should import from
`airlfow.executors.celery_executor` instead.

Closes #2590 from
lxneng/bugfix/fix_pkg_importerror_in_run_task_view


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/dca9ab3f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/dca9ab3f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/dca9ab3f

Branch: refs/heads/master
Commit: dca9ab3f8ad7811fcec54f67ae99c81b7df231b3
Parents: 034b7ed
Author: Eric Lo <lx...@gmail.com>
Authored: Wed Sep 27 10:09:10 2017 -0700
Committer: Chris Riccomini <cr...@apache.org>
Committed: Wed Sep 27 10:09:17 2017 -0700

----------------------------------------------------------------------
 airflow/www/views.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/dca9ab3f/airflow/www/views.py
----------------------------------------------------------------------
diff --git a/airflow/www/views.py b/airflow/www/views.py
index bbee65f..a0a0999 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -856,7 +856,7 @@ class Airflow(BaseView):
 
         try:
             from airflow.executors import GetDefaultExecutor
-            from airflow.executors import CeleryExecutor
+            from airflow.executors.celery_executor import CeleryExecutor
             executor = GetDefaultExecutor()
             if not isinstance(executor, CeleryExecutor):
                 flash("Only works with the CeleryExecutor, sorry", "error")