airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From siddharth anand <>
Subject Fwd: XCOM value within a DAG
Date Fri, 21 Jul 2017 17:00:31 GMT
---------- Forwarded message ----------
From: Vadzim Nemchenko <>
Date: Thu, Jul 20, 2017 at 11:15 AM
Subject: XCOM value within a DAG

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']

It works fine. I have a dag definition file ( 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

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message