Repository navigation
Commit 41d897f
authored
fix:
* fix: use parent's map_index for XCom lookup in NotPreviouslySkippedDep
When an unmapped SkipMixin parent (e.g., LatestOnlyOperator) is upstream
of a dynamically mapped task, the child task must look up XCom using
map_index=-1 (the parent's XCom storage index) rather than the child's
own map_index. This fix ensures mapped downstream TIs are correctly
skipped when appropriate.
Fixes #62118
* fix: apply ruff formatting and import sorting
- Split long multi-argument function call across lines
- Fix import order: move XComModel import before providers
* ci: trigger CI re-run (transient docs build cache failure)LatestOnlyOperator not working if direct upstream of Dynamic Task Map (#62287)1 parent d349918 commit 41d897f
2 files changed
Lines changed: 62 additions & 2 deletions
File tree
- airflow-core
- src/airflow/ti_deps/deps
- tests/unit/ti_deps/deps
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
58 | 58 | | |
59 | 59 | | |
60 | 60 | | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
61 | 65 | | |
62 | | - | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
63 | 70 | | |
64 | 71 | | |
65 | 72 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
| 25 | + | |
25 | 26 | | |
26 | 27 | | |
27 | 28 | | |
28 | | - | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
29 | 34 | | |
30 | 35 | | |
31 | 36 | | |
| |||
161 | 166 | | |
162 | 167 | | |
163 | 168 | | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
| 175 | + | |
| 176 | + | |
| 177 | + | |
| 178 | + | |
| 179 | + | |
| 180 | + | |
| 181 | + | |
| 182 | + | |
| 183 | + | |
| 184 | + | |
| 185 | + | |
| 186 | + | |
| 187 | + | |
| 188 | + | |
| 189 | + | |
| 190 | + | |
| 191 | + | |
| 192 | + | |
| 193 | + | |
| 194 | + | |
| 195 | + | |
| 196 | + | |
| 197 | + | |
| 198 | + | |
| 199 | + | |
| 200 | + | |
| 201 | + | |
| 202 | + | |
| 203 | + | |
| 204 | + | |
| 205 | + | |
| 206 | + | |
| 207 | + | |
| 208 | + | |
| 209 | + | |
| 210 | + | |
| 211 | + | |
| 212 | + | |
| 213 | + | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
0 commit comments