nagasrisai opened a new pull request, #64576:
URL: https://github.com/apache/airflow/pull/64576
Noticed that `xcom_pull()` wasn't respecting the `default` argument in a
specific case. If you call it without specifying `map_indexes`, it internally
calls `XCom.get_all()` for each task id. When that comes back `None` (meaning
the task hasn't pushed any XCom yet), the result was always `None` regardless
of what you passed as `default`.
The explicit `map_indexes` path a few lines below already had
`xcoms.append(default)` — this just fixes the branch above to match:
```python
# before
if values is None:
xcoms.append(None)
# after
if values is None:
xcoms.append(default)
```
Added a test that covers this directly and a newsfragment.
Closes #64295
--
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]
