summaryrefslogtreecommitdiff
path: root/heat/db
diff options
context:
space:
mode:
Diffstat (limited to 'heat/db')
-rw-r--r--heat/db/sqlalchemy/api.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/heat/db/sqlalchemy/api.py b/heat/db/sqlalchemy/api.py
index 1313d22fa..5ad21185d 100644
--- a/heat/db/sqlalchemy/api.py
+++ b/heat/db/sqlalchemy/api.py
@@ -234,6 +234,8 @@ def resource_get_all(context):
return results
+@oslo_db_api.wrap_db_retry(max_retries=3, retry_on_deadlock=True,
+ retry_interval=0.5, inc_retry_interval=True)
def resource_purge_deleted(context, stack_id):
filters = {'stack_id': stack_id, 'action': 'DELETE', 'status': 'COMPLETE'}
query = context.session.query(models.Resource)
@@ -1319,6 +1321,8 @@ def purge_deleted(age, granularity='days', project_id=None, batch_size=20):
break
+@oslo_db_api.wrap_db_retry(max_retries=3, retry_on_deadlock=True,
+ retry_interval=0.5, inc_retry_interval=True)
def _purge_stacks(stack_infos, engine, meta):
"""Purge some stacks and their releated events, raw_templates, etc.