サブタスクでのAirFlowダグIDアクセス

Question

私は毎日実行するようにスケジュールされた3つのbashタスクを持つDAGを持っています。

すべてのbashスクリプトで、dagインスタンス（PIDの可能性あり）の一意のIDにアクセスしたいと考えています。

これを行う方法はありますか？

私はワークフローxmlまたはjavaコードでWORKFLOW_IDにアクセスできるOozieと同様の機能を探しています。巴里

Answer 1

は、私はそのPythonオブジェクトという事実を利用した

誰かが「気流DAGにどのようにビルドを使用して、カスタム変数」に気流のドキュメントを

を私を指すことができる多くのおかげでdagは現在のダグの名前を表示します。だから、僕はdag名前変更するにはJinja2のを使用します。ハックの

{{ dag | replace('<DAG: ', '') | replace('>', '') }} 

ビットを、それが動作します。

ので、

clear_upstream = BashOperator(task_id='clear_upstream', 
    trigger_rule='all_failed', 
    bash_command=""" 
     echo airflow clear -t upstream_task -c -d -s {{ ts }} -e {{ ts }} {{ dag | replace('<DAG: ', '') | replace('>', '') }} 
    """ 
)