我有一个自定义运算符,它推送 XCOM 值,如下所示:
...
task_instance = context['task_instance']
task_instance.xcom_push("list_of_files",file_list)
...
Run Code Online (Sandbox Code Playgroud)
它工作正常。我有一个 dag 定义文件 (my_dag.py),我在其中使用自己的运算符创建了一个任务,它推送 XCOM 值,然后我想通过使用此 xcom 值在循环中执行 for。怎么拉?