File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
temporal-sdk/src/test/java/io/temporal/workflow/signalTests Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 47
47
import org .junit .Test ;
48
48
49
49
public class SignalContinueAsNewNonDeterminism {
50
- private static final Semaphore workflowTaskProcessed = new Semaphore (1 );
50
+ private static final Semaphore workflowTaskProcessed = new Semaphore (0 );
51
51
52
52
private static final CompletableFuture <Boolean > continueAsNew = new CompletableFuture <>();
53
53
@@ -78,10 +78,11 @@ public void testSignalContinueAsNewNonDeterminism()
78
78
79
79
WorkflowClient .start (client ::execute , false );
80
80
for (int i = 0 ; i < 5 ; i ++) {
81
- workflowTaskProcessed .acquire ();
82
81
client .signal ();
82
+ workflowTaskProcessed .acquire ();
83
83
}
84
84
continueAsNew .complete (true );
85
+
85
86
// Force replay, expected to fail with NonDeterministicException
86
87
testWorkflowRule .invalidateWorkflowCache ();
87
88
client .signal ();
You can’t perform that action at this time.
0 commit comments