uranusjr commented on code in PR #30330:
URL: https://github.com/apache/airflow/pull/30330#discussion_r1161532791
##########
airflow/www/utils.py:
##########
@@ -812,6 +812,25 @@ def get_col_default(self, col_name: str) -> Any:
filter_converter_class = AirflowFilterConverter
+class DagRunCustomSQLAInterface(CustomSQLAInterface):
+ """
+ Overwrite of custom delete and delete_all methods for speeding up
+ the DagRun deletion when DagRun has a lot of task instances.
+ The default cascade deletion was performing very slowly when task
instances were more than 10k.
+
+ """
Review Comment:
```suggestion
"""Custom interface to allow faster deletion.
The ``delete`` and ``delete_all`` methods are overridden to speed up
deletion when a DAG run has a lot of related task instances. Relying on
SQLAlchemy's cascading deletion is comparatively slow in this situation.
"""
```
--
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]
