flush stream each time

Author: Nanguage

executor/engine/__init__.py

@@ -1,7 +1,7 @@
 from .core import Engine, EngineSetting
 from .job import LocalJob, ThreadJob, ProcessJob
 
-__version__ = '0.3.1'
+__version__ = '0.3.2'
 
 __all__ = [
     'Engine', 'EngineSetting',

executor/engine/job/extend/subprocess.py

@@ -120,7 +120,8 @@ def _run_cmd(runner: ProcessRunner):  # pragma: no cover
                     runner.run(**pkwargs)
                     with open(path_stdout, 'w') as fo, \
                          open(path_stderr, 'w') as fe:
-                        retcode = runner.write_stream_until_stop(fo, fe)
+                        retcode = runner.write_stream_until_stop(
+                            fo, fe, flush_streams_each_time=True)
                     return retcode
             else:
                 def _run_cmd(runner: ProcessRunner):