Create joint submit script

src/ert/scheduler/driver.py

@@ -13,6 +13,14 @@
 """Bash and other shells add an offset of 128 to the signal value when a process exited due to a signal"""
 
 
+def create_submit_script(runpath: Path, executable: str, args: tuple[str, ...]) -> str:
+    return (
+        "#!/usr/bin/env bash\n"
+        f"cd {shlex.quote(str(runpath))}\n"
+        f"exec -a {shlex.quote(executable)} {executable} {shlex.join(args)}\n"
+    )
+
+
 class FailedSubmit(RuntimeError):
     pass
 

src/ert/scheduler/lsf_driver.py

@@ -27,7 +27,7 @@
     get_args,
 )
 
-from .driver import SIGNAL_OFFSET, Driver, FailedSubmit
+from .driver import SIGNAL_OFFSET, Driver, FailedSubmit, create_submit_script
 from .event import Event, FinishedEvent, StartedEvent
 
 _POLL_PERIOD = 2.0  # seconds
@@ -309,12 +309,7 @@ async def submit(
 
         arg_queue_name = ["-q", self._queue_name] if self._queue_name else []
         arg_project_code = ["-P", self._project_code] if self._project_code else []
-
-        script = (
-            "#!/usr/bin/env bash\n"
-            f"cd {shlex.quote(str(runpath))}\n"
-            f"exec -a {shlex.quote(executable)} {executable} {shlex.join(args)}\n"
-        )
+        script = create_submit_script(runpath, executable, args)
         script_path: Optional[Path] = None
         try:
             with NamedTemporaryFile(

src/ert/scheduler/openpbs_driver.py

@@ -23,7 +23,7 @@
     get_type_hints,
 )
 
-from .driver import Driver, FailedSubmit
+from .driver import Driver, FailedSubmit, create_submit_script
 from .event import Event, FinishedEvent, StartedEvent
 
 logger = logging.getLogger(__name__)
@@ -241,11 +241,7 @@ async def submit(
             [] if self._keep_qsub_output else ["-o", "/dev/null", "-e", "/dev/null"]
         )
 
-        script = (
-            "#!/usr/bin/env bash\n"
-            f"cd {shlex.quote(str(runpath))}\n"
-            f"exec -a {shlex.quote(executable)} {executable} {shlex.join(args)}\n"
-        )
+        script = create_submit_script(runpath, executable, args)
         name_prefix = self._job_prefix or ""
         qsub_with_args: List[str] = [
             str(self._qsub_cmd),

src/ert/scheduler/slurm_driver.py

@@ -17,7 +17,7 @@
     Tuple,
 )
 
-from .driver import SIGNAL_OFFSET, Driver, FailedSubmit
+from .driver import SIGNAL_OFFSET, Driver, FailedSubmit, create_submit_script
 from .event import Event, FinishedEvent, StartedEvent
 
 SLURM_FAILED_EXIT_CODE_FETCH = SIGNAL_OFFSET + 66
@@ -181,11 +181,7 @@ async def submit(
         if runpath is None:
             runpath = Path.cwd()
 
-        script = (
-            "#!/usr/bin/env bash\n"
-            f"cd {shlex.quote(str(runpath))}\n"
-            f"exec -a {shlex.quote(executable)} {executable} {shlex.join(args)}\n"
-        )
+        script = create_submit_script(runpath, executable, args)
         script_path: Optional[Path] = None
         try:
             with NamedTemporaryFile(