Properly decode cluster info in callbacks
Fixes
@@ -348,6 +348,7 @@ def parse_slowlog_get(response, **options):
def parse_cluster_info(response, **options):
+ response = nativestr(response)
return dict(line.split(':') for line in response.splitlines() if line)
@@ -370,6 +371,7 @@ def _parse_node_line(line):
def parse_cluster_nodes(response, **options):
+ response = nativestr(response)
raw_lines = response
if isinstance(response, basestring):
raw_lines = response.splitlines()
