---------- Forwarded message ----------
From: Vadzim Nemchenko <[email protected]>
Date: Thu, Jul 20, 2017 at 11:15 AM
Subject: XCOM value within a DAG
To: [email protected]
Hello guys,
Your Google Group is locked for creating threads, so could you help me out
please with the issue below?
I have a custom operator which pushes XCOM value as below:
...
task_instance = context['task_instance']
task_instance.xcom_push("list_of_files",file_list)...
It works fine. I have a dag definition file (my_dag.py) where I create a
task by using my own operator, it pushes the XCOM value then I want to do
for in loop by using this xcom value. How to pull it?
Best Regards, Vadzim
