SSHOperator 在手动触发后显示 "No Status"

Question

我是 airflow 的新手，我编写了一个简单的 SSHOperator 来了解它的工作原理。

default_args = {
'start_date': datetime(2018,6,20)
}

dag = DAG(dag_id='ssh_test', schedule_interval = '@hourly',default_args=default_args)

sshHook = SSHHook(ssh_conn_id='testing')

t1 = SSHOperator(
    task_id='task1',
    command='echo Hello World',
    ssh_hook=sshHook,
    dag=dag)

当我在 UI 上手动触发它时，dag 显示运行状态，但操作员保持白色，没有状态。

我想知道为什么我的任务没有排队。有人有什么想法吗？如果这是有用的信息，我的 airflow.config 是默认设置。

即使这不是运行

dag=DAG(dag_id='test',start_date = datetime(2018,6,21), schedule_interval='0 0 * * *')
runMe = DummyOperator(task_id = 'testest', dag = dag)

Answer 1

确保除了 Airflow Web 服务器之外，您还启动了 Airflow Scheduler： airflow scheduler

Answer 2

检查气流调度程序是否运行
检查 airflow 网络服务器是否运行
检查网络中是否所有 DAG 都设置为开启 UI
检查 DAG 是否有过去的开始日期
检查 DAG 是否有适当的时间表（在时间表日期之前），该时间表显示在网络上 UI
检查 dag 是否有正确的 pool 和 queue。

SSHOperator 在手动触发后显示 "No Status"

SSHOperator showing "No Status" after manual trigger

airflow

airflow-scheduler