diff --git a/confluent_client/bin/noderun b/confluent_client/bin/noderun
index a250cef6..efe61a59 100755
--- a/confluent_client/bin/noderun
+++ b/confluent_client/bin/noderun
@@ -85,7 +85,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':