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无法执行任务的问题。

相关内容

热门资讯

教程攻略!皮皮跑胡子系统有鬼,... 教程攻略!皮皮跑胡子系统有鬼,epoker透视底牌,新2025版(有挂规律);教程攻略!皮皮跑胡子系...
专业讨论!闲来透视辅助器最新版... 专业讨论!闲来透视辅助器最新版,wepoker辅助真的假的,安装教程(有挂教学)是一款可以让一直输的...
最新研发!创思维激k看底牌辅助... 最新研发!创思维激k看底牌辅助,约局吧作弊脚本,新版2025教程(有挂头条);亲真的是有正版授权,小...
总算了解!打哈儿辅助软件,we... 总算了解!打哈儿辅助软件,wepoker手机版透视脚本,可靠技巧(有挂工具)是一款可以让一直输的玩家...
分辨真假!闲聚鱼虾蟹软件脚本,... 分辨真假!闲聚鱼虾蟹软件脚本,聚星ai辅助工具下载,靠谱教程(真实有挂)是一款可以让一直输的玩家,快...
实操分享!牵手跑得软件,wep... 实操分享!牵手跑得软件,wepoker高级辅助,详细教程(有挂方略);相信小伙伴都知道这个牵手跑得软...
揭秘关于!人海大厅挂什么好,w... 揭秘关于!人海大厅挂什么好,we poker辅助器v3.3,揭秘攻略(详细教程);1、点击下载安装,...
科技新动态!乐酷大厅怎么安装,... 您好,乐酷大厅怎么安装这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在...
一分钟揭秘!胡乐辅助脚本是真的... 一分钟揭秘!胡乐辅助脚本是真的假的,wpk有作弊吗,安装教程(有挂助手)是一款可以让一直输的玩家,快...
热点推荐!皮皮游戏辅助平台,w... 【福星临门,好运相随】;热点推荐!皮皮游戏辅助平台,wepoker破解游戏盒子,技巧教程(有挂分享)...