aboutsummaryrefslogtreecommitdiff
path: root/gn_libs
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2025-03-25 14:44:42 -0500
committerFrederick Muriuki Muriithi2025-03-25 14:44:42 -0500
commit27425e6d57634106d2991ad17414d45c490c931c (patch)
tree34e48d2aaa70ce4c99397f37d9947102d57d9ad0 /gn_libs
parentcbe2211a23e526936e523524259b39afa12c5f67 (diff)
downloadgn-libs-27425e6d57634106d2991ad17414d45c490c931c.tar.gz
Clean up after ourselves!
Diffstat (limited to 'gn_libs')
-rw-r--r--gn_libs/jobs/launcher.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/gn_libs/jobs/launcher.py b/gn_libs/jobs/launcher.py
index b7369a4..5edcd07 100644
--- a/gn_libs/jobs/launcher.py
+++ b/gn_libs/jobs/launcher.py
@@ -1,3 +1,4 @@
+import os
import sys
import time
import shlex
@@ -36,6 +37,10 @@ def run_job(conn, job, outputs_directory: Path):
# 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())
+
+ os.remove(stdout_file)
+ os.remove(stderr_file)
+ return process.poll()
except:
jobs.update_metadata(conn, job_id, "status", "error")
jobs.push_to_stream(conn, job_id, "stderr", traceback.format_exc())