エアフロー - 与えられたdag_idとrun_idの特定のtask_idを成功または失敗としてマーク

Question

dag_idに関連付けられた特定のtask_idとrun_idに成功/失敗をマークするために、外部（http要求を使用しますか？

私たちは、おそらく同時に実行されているいくつかの1000年のタスクを持つことができますので、..

私のタスクは、外部システム上で長時間実行するタスクであると私は私のタスクのステータスを見つけるために、システムをポーリングする必要はありません理想的には

• に私のタスクは、ジョブが終了すると
• が
• をスリープ状態に入る私の外部ジョブを開始するためにHTTPリクエストを作りたい、それが（外部システムや仕事の後のビルドアクション）の空気の流れを知らせますタスクが完了したこと（ta sk_id、dag_idとRUN_ID）

おかげ

Answer 1

エアフローdoesntのは、まだ残りのエンドポイントを持っています。しかし、あなたにはいくつかのオプションがあります - エアフローコマンドラインユーティリティを使用してジョブを成功にマークします。例えば。 Popenを使ったPythonで。 - 気流DBテーブルtask_instanceを直接更新する