uranusjr commented on code in PR #76420: URL: https://github.com/apache/airflow/pull/76420#discussion_r4467958504
########## airflow-core/src/airflow/models/dagrun.py: ########## Review Comment: The restore step now also brings back mapped tasks that were removed only because an earlier producer run returned a shorter list. For those, the log line and the `task_restored_to_dag` metric wrongly say the task was “previously removed from DAG”. Each restore also adds a new try. If the new list is still short, the scheduler removes the task again, leaving an empty try in its history. -- 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]
