ApacheAirflow2升级后无法执行任务
创始人
2024-09-05 09:01:31
0

问题可能是由于Airflow 2的默认Executor更改为“SequentialExecutor”,导致在Executor调度器中出现延迟。因此,需要更改为“LocalExecutor”或“CeleryExecutor”来解决该问题。

要更改为“LocalExecutor”:

在Airflow配置文件中,找到“executor =”一行,并将其更改为“executor = LocalExecutor”。

要更改为“CeleryExecutor”:

1.安装Celery库:

pip install celery

2.在Airflow配置文件中,找到“executor =”一行,并将其更改为“executor = CeleryExecutor”。

3.在Airflow目录下创建celery.py文件:

from airflow.executors.celery_executor import app as celery_app

celery = celery_app.conf.update( task_routes={ 'my_dag_id': { 'my_task_id': 'my_worker_name' } } )

4.将Celery worker绑定到队列:

celery worker -Queues my_worker_name

以上方法可以解决升级后Airflow 2无法执行任务的问题。

相关内容

热门资讯

6分钟举措!wepokerpl... 6分钟举措!wepokerplus作必弊(透视)真是是真的有辅助工具(哔哩哔哩)1)wepokerp...
第七分钟项目!wepoker怎... 第七分钟项目!wepoker怎么挂底牌(透视)其实真的是有辅助工具(哔哩哔哩)1、金币登录送、破产送...
5分钟机巧!德州透视插件(透视... 5分钟机巧!德州透视插件(透视)总是真的是有辅助辅助(哔哩哔哩)1、点击下载安装,德州透视插件脚本分...
4分钟技法!aapoker怎么... 4分钟技法!aapoker怎么开辅助器(透视)其实真的是有辅助脚本(哔哩哔哩)aapoker怎么开辅...
2分钟大纲!wepoker怎么... 2分钟大纲!wepoker怎么发冤家牌(透视)一贯是真的有辅助神器(哔哩哔哩)1、wepoker怎么...
第十分钟技法!wepoker私... 第十分钟技法!wepoker私人局怎么玩(透视)竟然真的是有辅助辅助(哔哩哔哩)1)wepoker私...
第十分钟方式!哈糖大菠萝开挂(... 第十分钟方式!哈糖大菠萝开挂(透视)其实存在有辅助工具(哔哩哔哩)1、实时哈糖大菠萝开挂透视辅助更新...
三分钟机巧!wepoker科技... 三分钟机巧!wepoker科技辅助器(透视)果然有辅助安装(哔哩哔哩)1、上手简单,内置详细流程视频...
8分钟技法!wepoker辅助... 8分钟技法!wepoker辅助插件功能(透视)切实有辅助透视(哔哩哔哩)wepoker辅助插件功能辅...
第4分钟手段!wepoker好... 第4分钟手段!wepoker好友局透视(透视)都是有辅助开挂(哔哩哔哩)1、下载好wepoker好友...