From cbe2211a23e526936e523524259b39afa12c5f67 Mon Sep 17 00:00:00 2001 From: Frederick Muriuki Muriithi Date: Tue, 25 Mar 2025 14:42:22 -0500 Subject: Fetch remaining content The process could complete running between checks for whether it is still running, so we need to fetch any left-over content. --- gn_libs/jobs/launcher.py | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'gn_libs') diff --git a/gn_libs/jobs/launcher.py b/gn_libs/jobs/launcher.py index 0b45a34..b7369a4 100644 --- a/gn_libs/jobs/launcher.py +++ b/gn_libs/jobs/launcher.py @@ -32,6 +32,10 @@ def run_job(conn, job, outputs_directory: Path): jobs.push_to_stream(conn, job_id, "stdout", stdout_in.read()) jobs.push_to_stream(conn, job_id, "stderr", stderr_in.read()) time.sleep(1) + + # Fetch any remaining content. + jobs.push_to_stream(conn, job_id, "stdout", stdout_in.read()) + jobs.push_to_stream(conn, job_id, "stderr", stderr_in.read()) except: jobs.update_metadata(conn, job_id, "status", "error") jobs.push_to_stream(conn, job_id, "stderr", traceback.format_exc()) -- cgit v1.2.3