Hi all, I am trying to pull the latest xcom value that could include the current task from a previous retry. In the UI I can see today's xcom value and yesterday's xcom value. I am retrying the task and unable to get today's value:
Attempt 1: context['ti'].xcom_pull(key=key, include_prior_dates=True) -> Yesterday's xcom value Attempt 2: context['ti'].xcom_pull(key=key) -> None Attempt 3: XCom.get_many(key=key, execution_date=context['execution_date'] + timedelta(days=1), include_prior_dates=True) -> List containing yesterday's xcom object It occurred to me at this point that maybe what I'm trying isn't possible with xcom, does anyone know? (FYI I'm on Airflow 1.10.3 but I've looked at the source code between this and master and seen no significant difference.) Thanks, Damian =============================================================================== Please access the attached hyperlink for an important electronic communications disclaimer: http://www.credit-suisse.com/legal/en/disclaimer_email_ib.html ===============================================================================
