在我的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删除的,所以我对问题可能是什么一无所知。有任何想法吗?
最佳答案
在链接的源代码中,有一行对我来说很有趣:
target_dttm = dag.following_schedule(context['execution_date'])
这意味着:如果您没有设置正确的DAG时间表,则此组件将尝试将其时间增量添加到
None
。我不确定问题中的代码仅仅是示例还是整件事。我的建议是:使用
None
以外的其他项添加DAG计划。
关于 Airflow TimeDeltaSensor因操作数类型不受支持而失败,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51321699/