小编rob*_*hur的帖子

如何execution_date在 dag 之外获取参数？

execution_min = "{{execution_date.strftime('%M') }}"

if execution_min == '00':
    logging.info('**** ' + "YES, It's 00")
    final_task = DummyOperator(
        task_id='task_y00',
        ...
        dag=dag
    )
else:
    logging.info('**** ' + "NOPE!!!")
    final_task = DummyOperator(
        task_id='task_n00',
        ...
        dag=dag
    )

我想用execution_date（特别是分钟）动态设置任务流

但是 Jinja 模板不能使用 template_fields = ['execution_date']

是否有任何解决方案可以从运算符外部（= DAG 本身）获取执行参数？？？？