我正试图在DAG中将一个值从一个Task传递到另一个Task。
我在DockerOperator任务中有一段代码：
'''ti = kwargs['ti']'''
'''command=ti.xcom_pull(key='return_value', task_ids=['run_this']),'''
然而，我从上面带有"ti.xcom_pull"的这一行中得到了错误"有效语法">。
这个DAG有两个任务，第一个是任务IDrun_This，它调用一个名为run_This_now的Python可调用函数，该函数将其作为返回语句：返回有效载荷
我正在查看"管理"下的UI-->XComs，并查看键"return_value"及其值，如任务ID"run_this"所示。
所以我知道我有一个带有返回值的XCom，但语法仍然会给我这个错误。
我正在运行Airflow 2.0.2
修复方法是在DockerOperator下使用double我不需要引用变量，因为run_this函数只通过"return"语句返回了一个值
command="{{ti.xcom_pull(task_ids = 'run_this')}}",