io utils - flush the stream on write to try and get better streaming …

…output
ploigos · Oct 20, 2021 · c630d15 · c630d15
1 parent 356a7a5
commit c630d15
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/ploigos_step_runner/utils/io.py b/src/ploigos_step_runner/utils/io.py
@@ -41,6 +41,7 @@ def create_sh_redirect_to_multiple_streams_fn_callback(streams):
     def sh_redirect_to_multiple_streams(data):
         for stream in streams:
             stream.write(data)
+            stream.flush()
 
     return sh_redirect_to_multiple_streams