summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRabi Mishra <ramishra@redhat.com>2019-08-17 09:54:37 +0530
committerRabi Mishra <ramishra@redhat.com>2019-08-20 06:19:05 +0000
commit36dab46bd5eee78034a31973ba1c4ad2db8fff7d (patch)
treeaf01b1932aa39f9dec6d5d756dfa257a78be8bdc
parent3476f1dcfce383e6c6031a118cfeb0c9871f0474 (diff)
downloadheat-36dab46bd5eee78034a31973ba1c4ad2db8fff7d.tar.gz
Add retry for sync_point_update_input_data
update_input_data in sync_point.sync() at times fails with DBDeadlock. Let's add retry like sync_point_create() Change-Id: Id4468801bcffa7a704d90d2e190ec8dbb9a0a00b Task: 36299 (cherry picked from commit ba9c42b9eb33b98ef68bea8d47852cfe54977b4d)
-rw-r--r--heat/db/sqlalchemy/api.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/heat/db/sqlalchemy/api.py b/heat/db/sqlalchemy/api.py
index 1642c33e6..3966b0e3a 100644
--- a/heat/db/sqlalchemy/api.py
+++ b/heat/db/sqlalchemy/api.py
@@ -1548,6 +1548,8 @@ def sync_point_get(context, entity_id, traversal_id, is_update):
)
+@oslo_db_api.wrap_db_retry(max_retries=3, retry_on_deadlock=True,
+ retry_interval=0.5, inc_retry_interval=True)
def sync_point_update_input_data(context, entity_id,
traversal_id, is_update, atomic_key,
input_data):