git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Use xcom in task retry


XComs push and pull should work as expected when a task is retried.  It
shouldn't make a difference, but are you using XComs with explicit keys or
the implicit return-based style? Is the push succeeding to the database?

Also can you show a simplified example of your code for this DAG?

Taylor

On Thu, Sep 6, 2018 at 12:48 PM Ben Gregory <ben@xxxxxxxxxxxxx> wrote:

> Hi Mishika --
>
> Posting this question on StackOverflow with some code examples you're using
> will likely be the fastest way to have this addressed.
>
> Just make sure to tag it with "airflow" so people can find it.
>
> - Ben
>
> On Thu, Sep 6, 2018 at 12:12 AM Mishika Singh <mishikaps@xxxxxxxxx> wrote:
>
> > I am pushing some [key,value] using xcom in an operator, which I want to
> > use when that task fails and comes for retry, for which I am using
> > xcom_pull in that operator. But it is returning None instead of that
> value.
> > Any pointer around this will be helpful.
> >
> >
> > --
> > Regards
> > Mishika Singh
> >
>
>
> --
>
> [image: Astronomer Logo] <https://www.astronomer.io/>
>
> *Ben Gregory*
> Data Engineer
>
> Mobile: +1-615-483-3653 • Online: astronomer.io <
> https://www.astronomer.io/>
>
> Download our new ebook. <http://marketing.astronomer.io/guide/> From
> Volume
> to Value - A Guide to Data Engineering.
>
-- 
*Taylor Edmiston*
Blog <https://blog.tedmiston.com/> | CV
<https://stackoverflow.com/cv/taylor> | LinkedIn
<https://www.linkedin.com/in/tedmiston/> | AngelList
<https://angel.co/taylor> | Stack Overflow
<https://stackoverflow.com/users/149428/taylor-edmiston>