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)
ebertbm:この設定で動作するようになったのですか? –