pierrejeambrun opened a new pull request, #26658: URL: https://github.com/apache/airflow/pull/26658
solves: https://github.com/apache/airflow/issues/14529 The goal of this PR is to collect feedback before going too deep into the implementation (tests, UI etc.). If you check at the issue thread, you will notice that there is quite a few concerns/inherent complexity to properly achieve TaskGroup clearing. (especially @potiuk who raised fair concerns about db deadlocks and topological order resolution for clearing tasks). This implements a simple 'POC', I was able to successfully clear simple task group, and also nested task groups. The function clearing tasks handles multiple task into one single transaction, which may resolve locks concerns. This code simply find the requested `TaskGroup` for clearing, recursively find all child tasks, then extract the partial_subset, and clear all those tasks. > Note: I also had to update the `check-init-decorator-arguments` static checks as `ast.unparse` was introduced in python 3.8. [doc](https://docs.python.org/3.10/library/ast.html#ast.unparse) -- 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]
