abhijeets25012-tech commented on code in PR #76669:
URL: https://github.com/apache/airflow/pull/76669#discussion_r4511866832
##########
airflow-core/src/airflow/models/dagrun.py:
##########
@@ -2411,6 +2412,14 @@ def _check_for_removed_or_restored_tasks(
continue
if ti.state == TaskInstanceState.REMOVED:
+ if mapping_unresolved:
Review Comment:
Thanks for pointing this out. I agree that `mapping_unresolved` alone
doesn't distinguish mapping-shrink restoration from a task being removed and
later re-added in a newer DAG version. I've narrowed the restoration condition
to avoid unintentionally changing the normal task re-addition behaviour and
preserve its metric and info log.
--
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]
