Skip to content

Commit 9b597e6

Browse files
committed
Fix buffer problems
1 parent 7be8c1c commit 9b597e6

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

supervisor_stdout.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,11 @@ def event_handler(event, response):
2121
line, data = response.split('\n', 1)
2222
headers = dict([ x.split(':') for x in line.split() ])
2323
for newline in data.splitlines():
24-
print( '[{0}] [{1}] {2}'.format(headers['processname'], headers['channel'], newline) )
24+
if (headers['channel'] == 'stdout'):
25+
sys.stdout.write( '[{0}] [{1}] {2}'.format(headers['processname'], headers['channel'], newline) )
26+
if (headers['channel'] == 'stderr'):
27+
sys.stderr.write( '[{0}] [{1}] {2}'.format(headers['processname'], headers['channel'], newline) )
28+
2529

2630
if __name__ == '__main__':
2731
main()

0 commit comments

Comments
 (0)