diff --git a/lib/ansible/modules/clustering/znode.py b/lib/ansible/modules/clustering/znode.py old mode 100644 new mode 100755 index fad04ae2024..71cd5007583 --- 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):