commit ca1df8f1f4d9f55da297b9759b8b9051ccc1b7b3
author Shad Ansari <shad@opennetworking.org> Mon Apr 15 23:38:17 2019 -0700
committer Shad Ansari <shad@opennetworking.org> Fri May 17 05:57:04 2019 +0000
tree 49963c575622a4c9419e53a6eafe85319230674e
parent a8f3bca575c659ea3d74203a4df018052a3a4647

Make etcd calls in callInThread

Change-Id: I3b4e28eb54440646fec050d2e2a13194c962c639

voltha/core/config/config_backend.py

diff --git a/voltha/core/config/config_backend.py b/voltha/core/config/config_backend.py
index d906348..84b9840 100644
--- a/voltha/core/config/config_backend.py
+++ b/voltha/core/config/config_backend.py
@@ -16,6 +16,7 @@
 from common.utils.asleep import asleep
 from requests import ConnectionError
 from twisted.internet.defer import inlineCallbacks, returnValue
+from twisted.internet import reactor
 
 import etcd3
 import structlog
@@ -226,10 +227,10 @@
         return self._retry('GET', *args, **kw)
 
     def _kv_put(self, *args, **kw):
-        return self._retry('PUT', *args, **kw)
+        reactor.callInThread(self._retry, 'PUT', *args, **kw)
 
     def _kv_delete(self, *args, **kw):
-        return self._retry('DELETE', *args, **kw)
+        reactor.callInThread(self._retry, 'DELETE', *args, **kw)
 
     def _retry(self, operation, *args, **kw):