在气流宏中传递变量

Question

请帮帮我 {{ execution_date.subtract(hours = 5) }} 在这里，我想将它作为变量传递，而不是硬编码 5。 我无法找到传递变量并最终使用变量值的方法。

Answer 1

你可以使用：

f'echo {{{{ execution_date.subtract(hours = {value}) }}}}'

使用 BashOperator 的示例：

value = 5 # This can be set dynamically
hello_my_task = BashOperator(
    task_id='my_task',
    bash_command=f'echo {{{{ execution_date.subtract(hours = {value}) }}}}',
    dag=dag,
)