From b81e5fb3ce06a914ed84dbade038a303e13e7f15 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 11 Oct 2019 09:53:01 -0400 Subject: [PATCH] Fix python3 issues with noderun and nodeshell --- confluent_client/bin/noderun | 2 ++ confluent_client/bin/nodeshell | 2 ++ 2 files changed, 4 insertions(+) diff --git a/confluent_client/bin/noderun b/confluent_client/bin/noderun index 10ee3975..0ecd7626 100755 --- a/confluent_client/bin/noderun +++ b/confluent_client/bin/noderun @@ -97,6 +97,7 @@ def run(): pernodeout[node] = [] pernodeout[node].append(data) else: + data = client.stringify(data) if options.nonodeprefix: sys.stderr.write(data) else: @@ -114,6 +115,7 @@ def run(): run_cmdv(node, cmdv, all, pipedesc) for node in sortutil.natural_sort(pernodeout): for line in pernodeout[node]: + line = client.stringify(line) if options.nonodeprefix: sys.stdout.write(line) else: diff --git a/confluent_client/bin/nodeshell b/confluent_client/bin/nodeshell index d0619f70..551a9e1e 100755 --- a/confluent_client/bin/nodeshell +++ b/confluent_client/bin/nodeshell @@ -98,6 +98,7 @@ def run(): pernodeout[node] = [] pernodeout[node].append(data) else: + data = client.stringify(data) if options.nonodeprefix: sys.stderr.write(data) else: @@ -115,6 +116,7 @@ def run(): run_cmdv(node, cmdv, all, pipedesc) for node in sortutil.natural_sort(pernodeout): for line in pernodeout[node]: + line = client.stringify(line) if options.nonodeprefix: sys.stdout.write(line) else: