气流 - 请检查"core"部分中"executor"键。当前值："CeleryExecutor"

Question

我正在尝试安装apache airflow，因此在airflow.cfg文件中将执行程序更改为Celery Executitor，但我在执行气流调度程序时遇到错误

请检查"；遗嘱执行人"；键入"；核心"；部分当前值："；CeleryExecutitor"；

Answer 1

在airflow src代码中，您可以找到以下块：

try:
executor_cls, import_source = cls.import_executor_cls(executor_name)
log.debug("Loading executor %s from %s", executor_name, import_source.value)
except ImportError as e:
log.error(e)
raise AirflowConfigException(
f'The module/attribute could not be loaded. Please check "executor" key in "core" section. '
f'Current value: "{executor_name}".'
)
log.info("Loaded executor: %s", executor_name)

所以真正的错误记录在AirflowConfigException之前，在您的情况下是cannot import name 'BaseKeyValueStoreBackend' from 'celery.backends.base'

确保在安装气流时安装了额外的芹菜依赖项：

pip install 'apache-airflow[celery]'