diff --git a/temporal-sdk/src/test/java/io/temporal/workflow/signalTests/SignalContinueAsNewNonDeterminism.java b/temporal-sdk/src/test/java/io/temporal/workflow/signalTests/SignalContinueAsNewNonDeterminism.java index 737d36448..e55e1989b 100644 --- a/temporal-sdk/src/test/java/io/temporal/workflow/signalTests/SignalContinueAsNewNonDeterminism.java +++ b/temporal-sdk/src/test/java/io/temporal/workflow/signalTests/SignalContinueAsNewNonDeterminism.java @@ -47,7 +47,7 @@ import org.junit.Test; public class SignalContinueAsNewNonDeterminism { - private static final Semaphore workflowTaskProcessed = new Semaphore(1); + private static final Semaphore workflowTaskProcessed = new Semaphore(0); private static final CompletableFuture continueAsNew = new CompletableFuture<>(); @@ -78,10 +78,11 @@ public void testSignalContinueAsNewNonDeterminism() WorkflowClient.start(client::execute, false); for (int i = 0; i < 5; i++) { - workflowTaskProcessed.acquire(); client.signal(); + workflowTaskProcessed.acquire(); } continueAsNew.complete(true); + // Force replay, expected to fail with NonDeterministicException testWorkflowRule.invalidateWorkflowCache(); client.signal();