可以为每个Airflow DAG设置不同的执行程序吗？

2019年7月21日 206次阅读

我希望将另一个DAG添加到现有的Airflow服务器.服务器当前正在使用LocalExecutor,但我可能希望我的DAG使用CeleryExecutor.似乎配置文件airflow.cfg只允许一个执行程序：

# The executor class that airflow should use. Choices include
# SequentialExecutor, LocalExecutor, CeleryExecutor
executor = LocalExecutor

是否可以配置Airflow,以便现有的DAG可以继续使用LocalExecutor,我的新DAG可以使用CeleryExecutor或自定义执行器类？我没有找到任何人这样做的例子,也没有发现Airflow文档中的任何内容.

最佳答案 似乎调度程序只会启动执行程序的一个实例.

点赞