diff options
| author | Frederick Muriuki Muriithi | 2025-03-25 14:42:22 -0500 |
|---|---|---|
| committer | Frederick Muriuki Muriithi | 2025-03-25 14:42:22 -0500 |
| commit | cbe2211a23e526936e523524259b39afa12c5f67 (patch) | |
| tree | c553babad64ad34d2900377f7fc894a9b8e4c0b6 /gn_libs/jobs/launcher.py | |
| parent | 876c72c711905e2057fe8e2351a0bd458965e13a (diff) | |
| download | gn-libs-cbe2211a23e526936e523524259b39afa12c5f67.tar.gz | |
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.
Diffstat (limited to 'gn_libs/jobs/launcher.py')
| -rw-r--r-- | gn_libs/jobs/launcher.py | 4 |
1 files changed, 4 insertions, 0 deletions
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()) |