Comment définir un SLA dans Airflow?

Question

Je voudrais définir un SLA dans un opérateur de capteur. Le documentation n'est pas trop clair sur l'utilisation de celui-ci. J'ai donc fait un test en utilisant l'opérateur S3KeySensor qui recherche un fichier qui n'existe pas. J'ai mis le sla à 30 secondes, j'espérais voir le record après 30 secondes dans le UI - en SLA rate - mais cela ne s'est pas produit. Qu'est-ce que je fais mal?

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) 

Answer 1

'sla': timedelta(hours=2), 

https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/tutorial.py#L44

Cette ligne a par exemple, à partir du Git d'écoulement d'air.