Re-throw exceptions when running in single job mode

Chronos-EaaS · Jan 6, 2025 · 97db913 · 97db913
1 parent 1efc42b
commit 97db913
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/main/java/ch/unibas/dmi/dbis/chronos/agent/AbstractChronosAgent.java b/src/main/java/ch/unibas/dmi/dbis/chronos/agent/AbstractChronosAgent.java
@@ -286,6 +286,10 @@ public void run() {
                         log.error( "Cannot reset job " + job.toString() + " to status FAILED." );
                     }
                     this.failed( job );
+
+                    if ( singleJobId != null ) {
+                        throw ex;
+                    }
                 } finally {
                     // (5.10) De-register the job at the observer
                     try {
@@ -311,11 +315,17 @@ public void run() {
         } catch ( InterruptedException ex ) {
             log.warn( "The chronos agent has been interrupted!", ex );
             Thread.currentThread().interrupt();
+            if ( singleJobId != null ) {
+                throw new RuntimeException( ex );
+            }
         } catch ( RuntimeException ex ) {
             log.error( "Unhandled RuntimeException! Will be re-thrown!", ex );
             throw ex;
         } catch ( Exception ex ) {
             log.error( "Unhandled Exception!", ex );
+            if ( singleJobId != null ) {
+                throw new RuntimeException( ex );
+            }
         }
 
         this.agent = null;