diff --git a/workflow/scripts/utils.py b/workflow/scripts/utils.py index ed90dc7661641dff2b0e8686359e07c8ba81a8b3..ffedd7f7a5ea467a38a8e11817eba97f2176a198 100644 --- a/workflow/scripts/utils.py +++ b/workflow/scripts/utils.py @@ -5,6 +5,7 @@ import shlex import logging +import subprocess logger = logging.getLogger(__name__) @@ -48,7 +49,7 @@ def run_pipe(steps, outfile=None): def block_on(command): process = subprocess.Popen(shlex.split(command), stderr=subprocess.STDOUT, stdout=subprocess.PIPE) for line in iter(process.stdout.readline, ''): - sys.stdout.write(line) + sys.stdout.buffer.write(line) process.wait() return process.returncode