Skip to content

Commit 2b1204d

Browse files
stidsborgclaude
andcommitted
Fix flaky EventDrivenFlowCompletesSuccessfully tests by using BusyWaitUntil
Replace fixed Task.Delay with BusyWaitUntil polling for Suspended status, matching the pattern already used in ParamlessFlowsTests. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent da9f6b4 commit 2b1204d

2 files changed

Lines changed: 2 additions & 4 deletions

File tree

Cleipnir.Tests/Flows/FlowsWithResultTests.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,10 +109,9 @@ public async Task EventDrivenFlowCompletesSuccessfully()
109109
var flows = new MessageDrivenFuncFlows(flowsContainer);
110110
await flows.Schedule("someInstanceId", "someParameter");
111111

112-
await Task.Delay(10);
113112
var controlPanel = await flows.ControlPanel(instanceId: "someInstanceId");
114113
controlPanel.ShouldNotBeNull();
115-
controlPanel.Status.ShouldBe(Status.Suspended);
114+
await controlPanel.BusyWaitUntil(c => c.Status == Status.Suspended);
116115

117116
var messageWriter = flows.MessageWriter("someInstanceId");
118117
await messageWriter.AppendMessage(new IntWrapper(2));

Cleipnir.Tests/Flows/UnitFlowsTests.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,10 +70,9 @@ public async Task EventDrivenFlowCompletesSuccessfully()
7070

7171
await flows.Schedule("someInstanceId", "someParameter");
7272

73-
await Task.Delay(10);
7473
var controlPanel = await flows.ControlPanel(instanceId: "someInstanceId");
7574
controlPanel.ShouldNotBeNull();
76-
controlPanel.Status.ShouldBe(Status.Suspended);
75+
await controlPanel.BusyWaitUntil(c => c.Status == Status.Suspended);
7776

7877
var eventSourceWriter = flows.MessageWriter("someInstanceId");
7978
await eventSourceWriter.AppendMessage(new IntWrapper(2));

0 commit comments

Comments
 (0)