Added registration of a FAILED resume job

Signed-off-by: coduz <alberto.codutti@eurotech.com>
eclipse · Mar 21, 2020 · 57a9ea3 · 57a9ea3
1 parent 0ba0336
commit 57a9ea3
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/...engine/api/src/main/java/org/eclipse/kapua/job/engine/queue/QueuedJobExecutionStatus.java b/...engine/api/src/main/java/org/eclipse/kapua/job/engine/queue/QueuedJobExecutionStatus.java
@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (c) 2019 Eurotech and/or its affiliates and others
+ * Copyright (c) 2019, 2020 Eurotech and/or its affiliates and others
  *
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v1.0
@@ -22,11 +22,22 @@ public enum QueuedJobExecutionStatus {
      * The {@link QueuedJobExecution} has been enqueued and it is waiting to be resumed.
      * <p>
      * This is the initial status in which a newly created {@link QueuedJobExecution} should be in.
+     *
+     * @since 1.1.0
      */
     QUEUED,
 
     /**
      * The {@link QueuedJobExecution} has been resumed and fired.
+     *
+     * @since 1.1.0
      */
-    PROCESSED
+    PROCESSED,
+
+    /**
+     * The {@link QueuedJobExecution} has failed to resume.
+     *
+     * @since 1.2.0
+     */
+    FAILED_TO_RESUME
 }
diff --git a/...c/main/java/org/eclipse/kapua/job/engine/jbatch/listener/QueuedJobExecutionCheckTask.java b/...c/main/java/org/eclipse/kapua/job/engine/jbatch/listener/QueuedJobExecutionCheckTask.java
@@ -86,6 +86,9 @@ public void run() {
                 } catch (Exception e) {
                     LOG.error("Resuming Job Execution ({}/{}): {}... ERROR!", i, queuedJobExecutions.getSize(), qje.getJobExecutionId(), e);
                     failedToResumeExecution++;
+
+                    qje.setStatus(QueuedJobExecutionStatus.FAILED_TO_RESUME);
+                    KapuaSecurityUtils.doPrivileged(() -> QUEUED_JOB_EXECUTION_SERVICE.update(qje));
                     continue;
                 }