summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rwxr-xr-x[-rw-r--r--]lib/ansible/modules/clustering/znode.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/lib/ansible/modules/clustering/znode.py b/lib/ansible/modules/clustering/znode.py
index fad04ae202..71cd500758 100644..100755
--- a/lib/ansible/modules/clustering/znode.py
+++ b/lib/ansible/modules/clustering/znode.py
@@ -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):