python 将任务示例try_number作为参数传递给bashOperator

nuypyhwy 于 2023-05-27 发布在 Python

关注(0)|答案(1)|浏览(155)

我想将try_number作为参数传递给当前任务。我正在尝试类似下面的东西，但它不工作

t_test_with_try_number = BashOperator(
task_id='test_try_number',
bash_command='echo "Try number: {{ ti.try_number }}, number1: {{ ti.try_number1 }}"',
args={
    "--try-number": {{ ti.try_number }}
},
dag=dag,
)

如何在args中使用try_number

python

来源：https://stackoverflow.com/questions/76338920/pass-task-instance-try-number-as-argument-to-bashoperator

1条答案

按热度按时间

tkclm6bt1#

为了使用来自task_instance（ti）的数据，您需要使用在BashOperator情况下为jinja模板化的env

BashOperator(
    task_id="test_try_number",
    bash_command="echo \"trynumber='$trynumber'\"",
    env={
        "trynumber": "{{ ti.try_number }}"
    }
)

赞(0）回复(0）举报 2023-05-27

我来回答

python 将任务示例try_number作为参数传递给bashOperator

1条答案

相关问题

热门标签

最新问答