気流 - ダグランの開始時間を取得

Question

気流のダグの実際の開始時間を取得することは可能ですか？開始時間とは、ダグの最初のタスクが実行を開始する正確な時間を意味します。

マクロを使用して実行日を取得できます。 trigger_dagを使用してジョブが実行された場合、これは開始時刻と呼ばれますが、ジョブが毎日実行された場合、{{ execution_date }}はyesterdays dateを返します。

私はまた、ダグコードの本体にdatetime.now().isoformat()を置き、それをタスクに渡そうとしましたが、これは、ダグ自体が開始されたときではなく、タスクが最初に呼び出された時刻を返すようです。あなたが述べたように

Answer 1

{{ dag_run.start_date }}はダグの実際の開始時刻を提供します

Answer 2

私は道を、次の午前：

を開始時点で私が意味する正確な時間をDAGの最初のタスクは

の実行を開始あなたはまだあなたのマクロでこれを行うことができます最初のタスク、すべての変数は、タスクインスタンスのクラスで見つけることができます。この{{ task.start_date }}

を試してみてください。 https://github.com/apache/incubator-airflow/blob/master/airflow/models.py#L746