2017-11-22 4 views
0

ローカルマシンのLocalExecutorからCeleryExecutorに切り替えようとしています。 pip install airflow[celery]を使用して必要なライブラリをインストールする必要があります。私もredisをインストールして実行しています。私は、バックグラウンドで実行されているのRedisとredis://localhost:6379からbroker urlcelery_result_backend両方のセットを持っているpipインストール後もCeleryExecutorが定義されていません[セロリー]

DEFAULT_EXECUTOR = CeleryExecutor() 
NameError: CeleryExecutor' is not defined 

:私はairflow workerを実行しようとすると

はしかし、私はエラーを取得します。私は間違って何をしていますか?

+0

に思えるその気流Webサーバ、気流スケジューラ、気流 'の順序worker'これは – user3776598

答えて

1

てみ開口部まで気流がインストールされ、これを実行しているPythonシェル:

>>> from airflow.executors.celery_executor import CeleryExecutor 

は、私はあなたがより多くの有益なエラーが出ると思います。

+0

が、私は同じエラーを取得するどのように動作するかの事項: ' DEFAULT_EXECUTOR = CeleryExecutor() NameError:name 'CeleryExecutor'が定義されていません。実際に少し循環しているようだ。 – user3776598

+0

うん、 '輸入セロリー'をしようとするとどう?それから何かエラー? –

+0

'セロリ 'が私のために働いています。私はそれが働くようになった。 「エアフローウェブサーバ」、「エアフロースケジューラ」、「エアフローワーカー」の順番になっているようです。 – user3776598

0

切り替えたように見えますが、気流はそれについてはわかりません。各気流コマンドを実行する前に、あなたはAIRFLOW_HOMEのenv変数が指定されていることを確認して、あなたはフォルダ〜/気流を持っているし、(自分のホームディレクトリに!)〜/ airflow.cfgを提出、それがデフォルトとして使用されるようにしていません(あなたのはAIRFLOW_HOMEを無視してください)。この問題について

詳細は:https://github.com/puckel/docker-airflow/issues/132

+0

〜/ airflow.cfgに 'executor = CeleryExecutor'を設定しました。これは気流のために私のセロリ労働者をオンにしませんか? – user3776598

関連する問題