fix python3 compatibility for znode module

kazoo client requires bytes and not string

(cherry picked from commit 2d98a2de68)
pull/37153/head
Grigory Starinkin 8 years ago committed by Toshio Kuratomi
parent 5911ee813a
commit 98b5ffec04

@ -111,6 +111,7 @@ except ImportError:
KAZOO_INSTALLED = False
from ansible.module_utils.basic import AnsibleModule
from ansible.module_utils._text import to_bytes
def main():
@ -232,13 +233,13 @@ class KazooCommandProxy():
if self.exists(path):
(current_value, zstat) = self.zk.get(path)
if value != current_value:
self.zk.set(path, value)
self.zk.set(path, to_bytes(value))
return True, {'changed': True, 'msg': 'Updated the znode value.', 'znode': path,
'value': value}
else:
return True, {'changed': False, 'msg': 'No changes were necessary.', 'znode': path, 'value': value}
else:
self.zk.create(path, value, makepath=True)
self.zk.create(path, to_bytes(value), makepath=True)
return True, {'changed': True, 'msg': 'Created a new znode.', 'znode': path, 'value': value}
def _wait(self, path, timeout, interval=5):

Loading…
Cancel
Save