insomnes commented on PR #46728:
URL: https://github.com/apache/airflow/pull/46728#issuecomment-2657423001
I am still not sure if this is the intended implementation or not, but it is
limited by the current execution API restriction of 1 XCom result in response.
I didn't touch it to not break anything.
Prints from original DAG example:
```python3
@dag.task
def xcom_pull(**context):
ti: TaskInstance = context["ti"]
# [1, 3, None, None, None, None]"
for x in [
ti.xcom_pull(task_ids=["identity", "foo", "plusfive"],
map_indexes=[0, 2]),
]:
print(x)
@dag.task
def xcom_multi_pull(nothing, **context):
ti: TaskInstance = context["ti"]
print("MY TI", ti.map_index)
# For ti 2
# [3, None, None]
for x in [
ti.xcom_pull(task_ids=["identity", "foo", "plusfive"],
map_indexes=None),
]:
print(x)
```
--
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]
