X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=n2vc%2Fn2vc_juju_conn.py;h=943d70d7dbec11f27e038696bff277e1132866c2;hb=60a3a96717d7c36ba7a65573da59a6bc039f5e28;hp=9ed225dc4235a530c809fea83523624e8d5c01a2;hpb=e6955004c1a68a3e370e67864d2a7370ea2d6e05;p=osm%2FN2VC.git diff --git a/n2vc/n2vc_juju_conn.py b/n2vc/n2vc_juju_conn.py index 9ed225d..943d70d 100644 --- a/n2vc/n2vc_juju_conn.py +++ b/n2vc/n2vc_juju_conn.py @@ -814,8 +814,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) + 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) @@ -824,7 +825,7 @@ class N2VCJujuConnector(N2VCConnector): return try: - async with self.delete_namespace_locks[namespace]: + async with delete_lock: libjuju = await self._get_libjuju(vca_id) # check arguments @@ -1135,7 +1136,6 @@ class N2VCJujuConnector(N2VCConnector): ) def _write_ee_id_db(self, db_dict: dict, ee_id: str): - # write ee_id to database: _admin.deployed.VCA.x try: the_table = db_dict["collection"]