기류 - 계단 달림 시작 시간을 받으십시오

Question

기류에서 계기판의 실제 시작 시간을 가져올 수 있습니까? 시작 시간이란, dag의 첫 번째 작업이 실행되기 시작한 정확한 시간을 의미합니다.

실행 날짜를 얻기 위해 매크로를 사용할 수 있다는 것을 알고 있습니다. trigger_dag를 사용하여 작업을 실행하면 시작 시간이라고 부르지 만 작업이 매일 실행되는 경우 {{ execution_date }}은 yesterdays date를 반환합니다.

나는 또한 dag 코드의 본문에 datetime.now().isoformat()을 놓고 작업에 전달하려고 시도했지만 이것은 dag 자체가 시작될 때가 아니라 작업이 먼저 호출 된 시간을 반환하는 것으로 보입니다. 당신이 언급 한 바와 같이

Answer 1

{{ dag_run.start_date }}은 dag의 실제 시작 시간을 제공합니다.

Answer 2

나는 방법을 다음입니다 : 시작 시간으로

나는 DAG의 첫 번째 작업은

당신은 여전히 ​​매크로를 사용하여이 작업을 수행 할 수 실행 시작 정확한 시간을 의미하여 첫 번째 작업, 모든 변수가 TaskInstance 클래스에서 찾을 수 있습니다이 {{ task.start_date }}

을 시도 : https://github.com/apache/incubator-airflow/blob/master/airflow/models.py#L746