DAG:
with DAG(
'A_airflow_api',
default_args=default_args,
description='A simple HTTP Operator example with templated data',
# schedule_interval='*/10 * * * *', # 每10分钟执行一次
schedule_interval='27 9 * * *', # 每天 17:05 (UTC)
# schedule_interval='@once', # 执行一次
start_date=datetime(2023, 1, 1,0,0),
catchup=False,
max_active_runs=3,
concurrency=3,
dagrun_timeout=timedelta(hours=10),
tags=['servier','example', 'tutorial','Easy_Taxi'],
is_paused_upon_creation=True
)