Shut down the executor forcibly to interrupt any stuck workflows

NitorCreations · Apr 18, 2020 · f0a78ee · f0a78ee
1 parent aba60d6
commit f0a78ee
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/nflow-engine/src/test/java/io/nflow/engine/internal/executor/WorkflowStateProcessorTest.java b/nflow-engine/src/test/java/io/nflow/engine/internal/executor/WorkflowStateProcessorTest.java
@@ -856,6 +856,7 @@ public void stateProcessingSeriesStopsOnShutdown() throws InterruptedException {
     executorService.shutdown();
     shutdownRequest.set(true);
     boolean wasTerminated = executorService.awaitTermination(5, SECONDS);
+    executorService.shutdownNow();
 
     assertTrue(wasTerminated);
   }