气流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
)

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

• 子任务：[2018-07-13 09：00：39,663] {models.py:1427}错误-+ =：'NoneType'和'datetime.timedelta'不受支持的操作数类型

气流版本为1.8.1。

该代码基本上是从Example Pipeline定义中提取出来的，因此我对问题可能不满意。有任何想法吗？

Answer 1

查看您链接的源代码，在这种情况下，有一行让我觉得很有趣：

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

这意味着：如果您没有设置正确的 DAG 计划，该组件将尝试将其时间增量添加到None.

我不确定问题中的代码只是一个例子还是整个事情。我的建议是：添加一个除 之外的 DAG 计划None。