bintocher opened a new pull request, #62287: URL: https://github.com/apache/airflow/pull/62287
## Summary Fixes `NotPreviouslySkippedDep` to correctly skip mapped downstream tasks when the parent is an unmapped `SkipMixin` operator (e.g., `LatestOnlyOperator`, `BranchPythonOperator`). The dependency check now queries XCom using the parent's map context instead of the child's. ## Issue Fixes #62118 ## Changes - Fixed `NotPreviouslySkippedDep._get_dep_statuses()` to use the parent's map context when pulling XCom data - Unmapped parents write XCom with `map_index=-1`, so we now query with `-1` instead of the child's `map_index` for unmapped parents - Added regression test `test_unmapped_parent_skip_mapped_downstream` that verifies mapped TIs are correctly skipped by an unmapped `SkipMixin` parent ## Testing - Added new unit test `test_unmapped_parent_skip_mapped_downstream` that simulates an unmapped `BranchPythonOperator` writing skip XCom with `map_index=-1` and verifies that a mapped downstream TI (with `map_index=0`) is correctly skipped - Verified the test passes with the fix and fails without it -- 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]
