Airflow TimeDeltaSensor因操作数类型不受支持而失败

Question

在我的DAG中，我使用以下命令创建了一个 TimeDeltaSensor :

from datetime import datetime, timedelta
from airflow.operators.sensors import TimeDeltaSensor 
wait = TimeDeltaSensor(
    task_id='wait',
    delta=timedelta(seconds=300),
    dag=dag
)

但是，当它运行时，我得到了错误

• Subtask: [2018-07-13 09:00:39,663] {models.py:1427} ERROR - unsupported operand type(s) for +=: 'NoneType' and 'datetime.timedelta'

Airflow 版本为1.8.1。

该代码基本上是从 Example Pipeline definition删除的，所以我对问题可能是什么一无所知。有任何想法吗？

Answer 1

在链接的源代码中，有一行对我来说很有趣:

target_dttm = dag.following_schedule(context['execution_date'])

这意味着:如果您没有设置正确的DAG时间表，则此组件将尝试将其时间增量添加到 None。

我不确定问题中的代码仅仅是示例还是整件事。我的建议是:使用 None以外的其他项添加DAG计划。