flush logfile before a subprocess is started

ccp4 · Nov 28, 2018 · 5e676f5 · 5e676f5
1 parent d1f9a3b
commit 5e676f5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/utils.py b/utils.py
@@ -69,6 +69,8 @@ def log_section(name):
             name = '%s %d' % (name, counter)
         _logfile_sections.add(name)
         _logfile.write('\n[%s]\n' % name)
+
+def log_flush():
         _logfile.flush()
 
 def log_value(key, value):

diff --git a/workflow.py b/workflow.py
@@ -623,6 +623,7 @@ def run_job(self, job, show_progress, new_line=True):
             utils.log_value('input', job.std_input)
         utils.log_value('prog', job.args[0])
         utils.log_value('args', ' '.join(pipes.quote(a) for a in job.args[1:]))
+        utils.log_flush()
         # job.args[0] = 'true'  # for debugging
         try:
             process = Popen(job.args, stdin=PIPE, stdout=PIPE, stderr=PIPE,