diff --git a/confluent_client/bin/nodeshell b/confluent_client/bin/nodeshell index 6db57f6a..d090e0ba 100755 --- a/confluent_client/bin/nodeshell +++ b/confluent_client/bin/nodeshell @@ -86,7 +86,7 @@ def run(): desc = pipedesc[r] node = desc['node'] data = True - while data and select.select([r], [], [], 0): + while data and select.select([r], [], [], 0)[0]: data = r.readline() if data: if desc['type'] == 'stdout':