Have job_dispatch.py safely terminate child processes on exception

equinor · Sep 24, 2024 · 07228b8 · 07228b8
1 parent 6587920
commit 07228b8
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/_ert/forward_model_runner/job_dispatch.py b/src/_ert/forward_model_runner/job_dispatch.py
@@ -13,7 +13,12 @@ def sigterm_handler(_signo, _stack_frame):
 def main():
     os.nice(19)
     signal.signal(signal.SIGTERM, sigterm_handler)
-    job_runner_main(sys.argv)
+    try:
+        job_runner_main(sys.argv)
+    except Exception as e:
+        pgid = os.getpgid(os.getpid())
+        os.killpg(pgid, signal.SIGTERM)
+        raise e
 
 
 if __name__ == "__main__":