에러 메시지
Traceback (most recent call last):
File "/home/airflow/sandbox/bin/airflow", line 8, in
sys.exit(main())
File "/home/airflow/sandbox/lib/python3.8/site-packages/airflow/main.py", line 40, in main
args.func(args)
File "/home/airflow/sandbox/lib/python3.8/site-packages/airflow/cli/cli_parser.py", line 47, in command
func = import_string(import_path)
File "/home/airflow/sandbox/lib/python3.8/site-packages/airflow/utils/module_loading.py", line 32, in import_string
module = import_module(module_path)
File "/usr/lib/python3.8/importlib/init.py", line 127, in import_module
return _bootstrap._gcd_import(name[level:], package, level)
File "", line 1014, in _gcd_import
File "", line 991, in _find_and_load
File "", line 975, in _find_and_load_unlocked
File "", line 671, in _load_unlocked
File "", line 848, in exec_module
File "", line 219, in _call_with_frames_removed
File "/home/airflow/sandbox/lib/python3.8/site-packages/airflow/cli/commands/celery_command.py", line 29, in
from flower.command import FlowerCommand
ImportError: cannot import name 'FlowerCommand' from 'flower.command' (/home/airflow/sandbox/lib/python3.8/site-packages/flower/command.py)airflow 2.1.0 version에서는 celery flower를 default로 제공하지 않아서 발생하는 문제로 보인다.(2.0.0 version으로 변경)
$ pip install --upgrade apache-airflow-providers-celery==2.0.0
설치 후
$ airflow celery flower
를 이용해서 flower를 실행하면 동작한다.
