Added a forced buffer flush on each worker stdin write (#2057)
This commit is contained in:
parent
06d46ac762
commit
2cc0d64619
|
|
@ -217,6 +217,7 @@ class SysCommandWorker:
|
|||
|
||||
if self.child_fd:
|
||||
return os.write(self.child_fd, data + (b'\n' if line_ending else b''))
|
||||
os.fsync(self.child_fd)
|
||||
|
||||
return 0
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue