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
index e6285879b..f1e8ad9c9 100644
--- 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);
   }