Luigi パイプラインの一部として、POST リクエストを使用して計算中のデータを待っているマイクロサービスに通知したいと考えています。
今までは を使ってRunAnywayTargetいましたが、データの変化率よりも早くルイージを起動させてしまうと困ります。だから私の質問は、
REST サービスへの POST リクエストの実行、Kafka へのメッセージの送信など、パイプラインで何かを実行するがデータの一部を作成しないタスクを作成するための最適なパターンは何ですか?
run メソッドで要求を実行する出力のないタスクを作成できることはわかっていますが、最初の実行中に何らかの理由でエンド サービスが失敗した場合、この NotificationTask を再実行するにはどうすればよいでしょうか? 依存関係が存在し、再度実行されることはありません。