tirkarthi commented on issue #22995: URL: https://github.com/apache/airflow/issues/22995#issuecomment-1098356253
I guess the issue occurs that after setting state the subdags are cleared with `only_failed` as always True. Hence if the state being set is failed then it goes on to clear the state. So we need to make sure `only_failed` is False when the state being set is already `failed`. In addition to this the `exclude_task_ids` only includes the main `task_id` and with downstream set as True the other `altered` task_ids that includes downstream task ids should also be added to this list so that the state is not cleared. I can raise a PR for this. https://github.com/apache/airflow/blob/a801ea3927b8bf3ca154fea3774ebf2d90e74e50/airflow/models/dag.py#L1690-L1699 -- 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]
