diff --git a/code/queue.rb b/code/queue.rb index f4227e3..f83748f 100644 --- a/code/queue.rb +++ b/code/queue.rb @@ -338,9 +338,9 @@ def run_queue_script!(msg) IO.for_fd(child_rd_fd).close rescue nil f = File.open(job_path + "/stdio.log", "a") + f.sync = true pfx = "#{Process.pid} - #{Time.now} -" f.write("\n#{pfx} RQ START - #{script_path}\n") - f.flush $stdin.close $stdout.reopen f