parallelvirtualcluster
/
pvc
1
0
Fork 0
Code Issues 11 Pull Requests Projects Releases 111 Wiki Activity

Fix bug with sub self command path/key

This commit is contained in:
Joshua Boniface 2021-06-10 00:49:01 -04:00
parent 058c2ceef3
commit 8dc9fd6dcb
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
daemon-common/zkhandler.py
View File

@ -226,7 +226,7 @@ class ZKHandler(object):
path = self.get_schema_path(key) path = self.get_schema_path(key)
if not self.exists(path): if not self.exists(key):
# Creating a new key # Creating a new key
transaction.create(path, str(value).encode(self.encoding)) transaction.create(path, str(value).encode(self.encoding))
@ -264,7 +264,7 @@ class ZKHandler(object):
for key in keys: for key in keys:
path = self.get_schema_path(key) path = self.get_schema_path(key)
if self.exists(path): if self.exists(key):
try: try:
self.zk_conn.delete(path, recursive=recursive) self.zk_conn.delete(path, recursive=recursive)
except Exception as e: except Exception as e:
@ -313,10 +313,10 @@ class ZKHandler(object):
destination_key = kkpair[1] destination_key = kkpair[1]
destination_path = self.get_schema_path(destination_key) destination_path = self.get_schema_path(destination_key)
if not self.exists(source_path): if not self.exists(source_key):
self.log("ZKHander error: Source key '{}' does not exist".format(source_path), state='e') self.log("ZKHander error: Source key '{}' does not exist".format(source_path), state='e')
return False return False
if self.exists(destination_path): if self.exists(destination_key):
self.log("ZKHander error: Destination key '{}' already exists".format(destination_path), state='e') self.log("ZKHander error: Destination key '{}' already exists".format(destination_path), state='e')
return False return False