airflow - 如何在Airflow中设置SLA？

我想在传感器运算符(operator)中设置SLA。 documentation对其用法不太清楚。因此，我使用S3KeySensor运算符进行了测试，该运算符正在查找不存在的文件。我将sla设置为30秒，我希望在UI中看到30秒后的记录-在SLA未命中-但这没有发生。我究竟做错了什么？

inputsensor = S3KeySensor(
    task_id='check_for_files_in_s3',
    bucket_key='adp/backload/20136585/',
    wildcard_match=True,
    bucket_name='weblogs-raw',
    s3_conn_id='AWS_S3_CENTRAL',
    timeout=120,
    poke_interval=10,
    sla=timedelta(seconds=30),
    dag=dag)

inputsensor.set_downstream(next_step)

最佳答案

'sla': timedelta(hours=2),

Airflow Git存储库中的一个示例:airflow/example_dags/tutorial.py#L54。

关于airflow - 如何在Airflow中设置SLA？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/44071519/