2017-05-19 14 views
1

センサオペレータにSLAを設定したいと思います。 documentationの使用についてあまり明確ではありません。そこで、存在しないファイルを探しているS3KeySensor演算子を使ってテストを行いました。私はSLAを30秒に設定しましたが、SLAミスでは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) 
+0

ebertbm:この設定で動作するようになったのですか? –

答えて

関連する問題