airflow default_args

airflow_default_args.py

default_args = {
    "owner": "airflow",
    # 何時開始這個cronjob
    "start_date": airflow.utils.dates.days_ago(2),
    # 何時結束
    #"end_date": datetime(2019, 12, 30),
    # 昨天失敗今天就不會跑了
    "depends_on_past": False,
    # 失敗會通知的email
    "email": ["xxxx@gmail.com"],
    "email_on_failure": False,
    "email_on_retry": False,
    # retry times
    "retries": 1,
    # timespan between workflow
    "retry_delay": timedelta(minutes=5),
}