我试图理解为什么你要在
with
语句末尾纠正特定变量?
从日期时间导入日期时间,时间增量
从气流导入DAG 从airflow.operators.bash导入BashOperator
default_args = {
'owner': 'coder2j',
'retries': 5,
'retry_delay': timedelta(minutes=5)
}
with DAG(
default_args=default_args,
dag_id="dag_with_cron_expression_v04",
start_date=datetime(2021, 11, 1),
schedule_interval='0 3 * * Tue-Fri'
) as dag:
task1 = BashOperator(
task_id='task1',
bash_command="echo dag with cron expression!"
)
task1 # What does this mean ?
这个例子取自这里。
为什么只将
task1
变量留在最后?
你说得对,没有理由。另外,带有赋值的变量 task1 也可以被删除。只是:
with DAG(
default_args=default_args,
dag_id="dag_with_cron_expression_v04",
start_date=datetime(2021, 11, 1),
schedule_interval='0 3 * * Tue-Fri'
) as dag:
BashOperator(
task_id='task1',
bash_command="echo dag with cron expression!"
)