shahar1 commented on issue #43883: URL: https://github.com/apache/airflow/issues/43883#issuecomment-2540124333
> Shouldn’t `downstream_task_ids` still contain the unexpanded base task in this case? Something still seems off to me. And we should probably fix the operator in any case. After spending some more time, I've figured that you should be correct, and the problem seems to be actually here (see TODO comment just above it): https://github.com/apache/airflow/blob/caa90a18d0790fb51c919485b749047d96c315c0/airflow/models/taskinstance.py#L1331 Until this point, `task` contains the `downstream_task_ids` - but due to the early return of mapped operators, it's not recorded in the downstream tasks. The hacky solution seems to be pushing the `downstream_task_ids` for into a hidden xcom, so the mapped short-circuit will be able it to utilize it - but I'm also open for suggestions :) -- 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]
