2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-16 10:39:23 +00:00

Fix nodeshell hang on incomplete lines

readline would hang because the filehandle was really not ready.
This commit is contained in:
Jarrod Johnson 2018-03-19 08:45:13 -04:00
parent 026a027603
commit f88e0bca4c

View File

@ -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':