小编Non*_* S.的帖子

现在，我使用这样的变量创建多个任务，并且效果很好。

with DAG(....) as dag:
    body = Variable.get("config_table", deserialize_json=True)
    for i in range(len(body.keys())):
        simple_task = Operator(
            task_id = 'task_' + str(i),
            .....

但出于某种原因我需要使用 XCOM 值而不是使用变量。是否可以动态创建带有XCOM拉值的任务？

我尝试像这样设置值但它不起作用

body = "{{ ti.xcom_pull(key='config_table', task_ids='get_config_table') }}"