-1
私は気流ダグでこの流れをしようとしています。気流 - なぜトリガールール "One done"がないのですか？何か不足していますか？
- タスク1：s3（s3センサー）にファイルが存在するかどうかを確認します。新しいファイルが見つからない場合は、タスク4にスキップしてください。
- タスク2：タスク1が基準を満たしている場合は、ローカルフォルダ内の既存のファイルを削除してください。
- タスク3：タスク2が完了したら、ローカルフォルダ
- タスク4：いずれの場合も、（フォルダ内のファイルのみを使用して）表を更新
私は明らかに、私はone_failed追加する場合は、タスク4.に追加するにはどのようなトリガーのルールを確認していませんファイルが存在する場合、タスクは実行されません。
"all_done"を追加した場合、どちらのパスでもダグがタスクをスキップするため、実行されることはありません（これは目的全体です）。
どうすればよいですか？私はここに何かを見逃していると思います...
ありがとうございます。
UPDATE
また、タイムアウトになったときに、私のs3keysensorが「失敗」の状態をトリガされていないようです。ログに「Snap、time is out」と表示されても、黄色で表示されます。
失敗を引き起こすはずです。これはドキュメントからのものです。 "センサーオペレータは一定の時間間隔で実行し続け、 の基準に達すると成功し、タイムアウトした場合には失敗します。
このメッセージは、コンソール「これらのタスクはデッドロックされています：{...}」に表示されます。ダグは走り続けない。タスク4を実行できません！私も同じ開始日と終了日のバックフィルで試していますが、これは正しいですか？