Add deleting lock to K8sJujuConnector

[osm/N2VC.git] / n2vc / n2vc_juju_conn.py

diff --git a/n2vc/n2vc_juju_conn.py b/n2vc/n2vc_juju_conn.py
index f077b40..fb36809 100644 (file)
--- a/n2vc/n2vc_juju_conn.py
+++ b/n2vc/n2vc_juju_conn.py
@@ -794,8 +794,9 @@ class N2VCJujuConnector(N2VCConnector):
         will_not_delete = False
         if namespace not in self.delete_namespace_locks:
             self.delete_namespace_locks[namespace] = asyncio.Lock(loop=self.loop)
         will_not_delete = False
         if namespace not in self.delete_namespace_locks:
             self.delete_namespace_locks[namespace] = asyncio.Lock(loop=self.loop)

+        delete_lock = self.delete_namespace_locks[namespace]

 
 

-        while self.delete_namespace_locks[namespace].locked():
+        while delete_lock.locked():

             will_not_delete = True
             await asyncio.sleep(0.1)
 
             will_not_delete = True
             await asyncio.sleep(0.1)
 


@@ -804,7 +805,7 @@ class N2VCJujuConnector(N2VCConnector):
             return
 
         try:
             return
 
         try:

-            async with self.delete_namespace_locks[namespace]:
+            async with delete_lock:

                 libjuju = await self._get_libjuju(vca_id)
 
                 # check arguments
                 libjuju = await self._get_libjuju(vca_id)
 
                 # check arguments