tirkarthi commented on issue #49737: URL: https://github.com/apache/airflow/issues/49737#issuecomment-2831062917
I just tried it in Airflow 2 and 3 to see the difference. The index calculation is same in both Airflow 2 and 3 but the usage varies as below In Airflow 2, Accessing `LazySequence[0]` goes on to get all the upstream task id xcom values and add offset for the calculated index and limit the result to 1 https://github.com/apache/airflow/blob/36c8975522a9241605ff34d0d78daa26f02a360b/airflow-core/src/airflow/utils/db.py#L1568-L1576 In Airflow 3, Accessing `LazyXComSequence[0]` goes on to get the upstream task id xcom values and uses the calculated index as `map_index` to the upstream which is different compared to Airflow 2 https://github.com/apache/airflow/blob/e2c9f9ba6dac07c4a2da0a41e09299cf1aa0efcb/task-sdk/src/airflow/sdk/execution_time/lazy_sequence.py#L151-L157 -- 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: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
