Merge pull request #444 from ExaWorks/process_launcher_msg

Detect launcher failure in the batch scheduler executors. Somehow this
ExaWorks · Feb 7, 2024 · a7a1256 · a7a1256
2 parents 03cc5d4 + ed0fc92
commit a7a1256
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/psij/executors/batch/batch_scheduler_executor.py b/src/psij/executors/batch/batch_scheduler_executor.py
@@ -567,7 +567,11 @@ def _read_aux_files(self, job: Job, status: JobStatus) -> None:
                 if status.message is None:
                     # only read output from submit script if another error message is not
                     # already present
-                    status.message = self._read_aux_file(job, '.out')
+                    out = self._read_aux_file(job, '.out')
+                    if out:
+                        launcher = self._get_launcher_from_job(job)
+                        if launcher.is_launcher_failure(out):
+                            status.message = launcher.get_launcher_failure_message(out)
                     logger.debug('Output from launcher: %s', status.message)
                 else:
                     self._delete_aux_file(job, '.out')