作者:fangziqiang | 来源:互联网 | 2023-02-01 11:03
我的气流服务器设置未运行任务,甚至没有示例dags。每当我进行手动运行时,DagRun
都会创建一个对象,该对象的状态正在运行,但始终保持不变。所有的问题都存在这个问题,而不仅仅是一个特定的问题。
每当我触发dag时,我都可以看到它出现在调度程序日志中,但是在celery日志中什么也没有出现。
我能够使用airflow test
命令“ dag ” airflow trigger
或“ drag ”中的手动触发器运行dag中的任务,但该命令不起作用。
我已经确保所有这三个命令都在运行,现在我也将它们置于管理程序之下。
气流网络服务器
气流调度器
气流工人
我尝试过的事情
我尝试将执行程序更改为无用LocalExecutor
的芹菜执行程序。但是那个
我目前正在使用Redis进行队列设置,例如:broker_url = redis://myhostname.com:6379/10
和结果后端设置celery_result_backend = amqp://guest:guest@localhost:5672
。我为这两种设置尝试过Rabbit-mq和redis的各种组合,但这并没有帮助
对于redis,我尝试使用两种格式amqp://
或pyamqp://
指定代理URL
我尝试更改芹菜版本,但这导致错误。我正在使用的Celery版本是celery == 4.0.2
这是在Ubuntu 14.04.5 LTS上运行的设置,我已经能够在Mac上成功运行本地版本的气流。
我已经坚持了好几个星期,有人可以帮我解决/调试这个问题吗?