Airflow 网络服务器为 dags 提供 cron 错误，其中 None 作为计划间隔

Question

我在 Linux AMI 中运行带有 LocalExecutor 和 PostgreSQL 数据库的 Airflow 1.9.0。我想手动触发 DAG，但是每当我创建一个将 schedule_interval 设置为 None 或 @once 的 DAG 时，网络服务器树视图就会崩溃并出现以下错误（我只显示最后一次调用）：

File "/usr/local/lib/python2.7/site-packages/croniter/croniter.py", line 467, in expand 
    raise CroniterBadCronError(cls.bad_length)
CroniterBadCronError: Exactly 5 or 6 columns has to be specified for iteratorexpression.

此外，当我手动触发 DAG 时，DAG 运行开始，但任务本身从未被安排。我环顾四周，但似乎我是唯一一个出现这种错误的人。有没有人遇到过这个错误并找到了解决方法？

触发问题的最小示例：

import datetime as dt
from airflow import DAG
from airflow.operators.bash_operator import BashOperator

default_args = {
    'owner': 'me'
}

bash_command = """
    echo "this is a test task"
"""

with DAG('schedule_test',
        default_args=default_args,
        start_date = dt.datetime(2018, 7, 24),
        schedule_interval='None',
        catchup=False
        ) as dag:

    first_task = BashOperator(task_id = "first_task", bash_command = bash_command)

Answer 1

试试这个：

• 将schedule_interval 设置为None，不带''，或者干脆不指定schedule_interval in your DAG。它设置为None as a default。在此处了解更多信息：airflow docs -- 搜索 schedule_interval
• 在 dag 底部为您的任务设置编排。

像这样：

import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.dummy_operator import DummyOperator

default_args = {
    'owner': 'me'
}

bash_command = """
    echo "this is a test task"
"""

with DAG('schedule_test',
        default_args=default_args,
        start_date = datetime(2018, 7, 24),
        schedule_interval=None,
        catchup=False
        ) as dag:

t1 = DummyOperator(
    task_id='extract_data',
    dag=dag
)

t2 = BashOperator(
    task_id = "first_task", 
    bash_command = bash_command
)

#####ORCHESTRATION#####
## It is saying that in order for t2 to run, t1 must be done.
t2.set_upstream(t1)