공기 흐름 DAG가 하루에 한 번씩 실행되는지 어떻게 확인할 수 있습니까?

Question

한 번에 하루를 실행하도록 DAG를 설정하려고합니다. 어떻게해야합니까?

"depends on past = True"를 시도했지만 이후에 각 작업이 실행되는지 만 확인합니다. 내가 원하는 것은 X 일 이후에 모든 일이 X + 1 일에 시작할 수있는 DAG 전에 실행된다는 것입니다.

Answer 1

이 페이지를 확인하십시오 : https://airflow.apache.org/scheduler.html#dag-runs
0 0 * * *으로 schedule_interval을 설정할 수 있습니다. 당신이 START_DATE 몇 일 전 트루 catchup_by_default을 = 설정 한 경우
는 공기 흐름은 모든 이전 작업이 먼저 당신은 활성 DAG 실행의 수를 제어 할 max_active_runs을 사용할 수 있습니다 schedule_interval

Answer 2

에 따라 일정을 실행 백필됩니다. 하나만 사용하도록 제한해야합니다.

dag = airflow.DAG(
    'customer_staging', 
    schedule_interval="@daily", 
    dagrun_timeout=timedelta(minutes=60), 
    template_searchpath=tmpl_search_path, 
    default_args=args, 
    max_active_runs=1)