气流服务器未运行作业

Bun*_*bit 5 airflow airflow-scheduler

我的气流服务器设置未运行任务,甚至没有示例dags。每当我进行手动运行时,DagRun都会创建一个对象,该对象的状态正在运行,但始终保持不变。所有的问题都存在这个问题,而不仅仅是一个特定的问题。

每当我触发dag时,我都可以看到它出现在调度程序日志中,但是在celery日志中什么也没有出现。

我能够使用airflow test命令“ dag ” airflow trigger或“ drag ”中的手动触发器运行dag中的任务,但该命令不起作用。

我已经确保所有这三个命令都在运行,现在我也将它们置于管理程序之下。

  1. 气流网络服务器
  2. 气流调度器
  3. 气流工人

我尝试过的事情

  • 我尝试将执行程序更改为无用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上成功运行本地版本的气流。

我已经坚持了好几个星期,有人可以帮我解决/调试这个问题吗?