...and take appropriate actions in this case.
Signed-off-by: Klaus Aehlig <[email protected]>
---
lib/jqueue/__init__.py | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/lib/jqueue/__init__.py b/lib/jqueue/__init__.py
index 48b16e7..2649618 100644
--- a/lib/jqueue/__init__.py
+++ b/lib/jqueue/__init__.py
@@ -1787,6 +1787,16 @@ class JobQueue(object):
break
if not raw_data:
+ logging.debug("No data available for job %s", job_id)
+ if int(job_id) == self.primary_jid:
+ logging.warning("My own job file (%s) disappeared;"
+ " this should only happy at cluster desctruction",
+ job_id)
+ if mcpu.lusExecuting[0] == 0:
+ logging.warning("Not in execution; cleaning up myself due to missing"
+ " job file")
+ logging.shutdown()
+ os._exit(1) # pylint: disable=W0212
return None
if writable is None:
--
2.2.0.rc0.207.ga3a616c