diff --git a/confluent_client/bin/nodeshell b/confluent_client/bin/nodeshell index f4d22488..feb9840c 100755 --- a/confluent_client/bin/nodeshell +++ b/confluent_client/bin/nodeshell @@ -72,7 +72,7 @@ def run(): run_cmdv(node, cmdv, all, pipedesc) else: pendingexecs.append((node, cmdv)) - if not all or exitcode + if not all or exitcode: sys.exit(exitcode) rdy, _, _ = select.select(all, [], [], 10) while all: