Pranaykarvi commented on PR #70199: URL: https://github.com/apache/airflow/pull/70199#issuecomment-5037285856
@kaxil @amoghrajesh Summary: cross-DAG `xcom_pull(..., include_prior_dates=True)` returned `None` because the cutoff subquery was keyed on `cls.dag_id` (the target DAG) paired with the caller's `run_id`, which never matches → NULL → all rows dropped. Fix resolves the cutoff from the pulling TI's own DAG run (via the TI token) and passes it to `get_many` as `prior_dates_before`; the old subquery stays as the fallback. No SDK/schema change. One call-out: same-DAG `xcom_pull(run_id=<earlier run>, include_prior_dates=True)` is now bounded by the caller's run date rather than that run's — this restores pre-3.2 semantics, but flagging it as an intentional behavior change. Happy to add a test pinning it if wanted. Locally: 94 passed incl. 2 new regression tests; both fail before the fix. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
