Skip to content

Commit 67c2147

Browse files
committed
Fix after ControlPanel's Restart-method removal
1 parent f906671 commit 67c2147

5 files changed

Lines changed: 13 additions & 8 deletions

File tree

Cleipnir.Tests/Flows/FlowsWithResultTests.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
using Cleipnir.ResilientFunctions;
12
using Cleipnir.ResilientFunctions.Domain;
23
using Cleipnir.ResilientFunctions.Helpers;
34
using Cleipnir.ResilientFunctions.Storage;
@@ -166,7 +167,7 @@ await Should.ThrowAsync<FatalWorkflowException<ArgumentException>>(() =>
166167
controlPanel.Status.ShouldBe(Status.Failed);
167168

168169
FailingFuncFlow.ShouldThrow = false;
169-
await controlPanel.Restart();
170+
await controlPanel.ScheduleRestart().Completion();
170171

171172
await controlPanel.Refresh();
172173
controlPanel.Status.ShouldBe(Status.Succeeded);

Cleipnir.Tests/Flows/ParamlessFlowsTests.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
using Cleipnir.ResilientFunctions;
12
using Cleipnir.ResilientFunctions.Domain;
23
using Cleipnir.ResilientFunctions.Messaging;
34
using Cleipnir.ResilientFunctions.Storage;
@@ -120,7 +121,7 @@ await Should.ThrowAsync<FatalWorkflowException<TimeoutException>>(() =>
120121
controlPanel.Status.ShouldBe(Status.Failed);
121122

122123
FailingParamlessFlow.ShouldThrow = false;
123-
await controlPanel.Restart();
124+
await controlPanel.ScheduleRestart().Completion();
124125

125126
await controlPanel.Refresh();
126127
controlPanel.Status.ShouldBe(Status.Succeeded);

Cleipnir.Tests/Flows/UnitFlowsTests.cs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
using Cleipnir.ResilientFunctions;
12
using Cleipnir.ResilientFunctions.Domain;
23
using Cleipnir.ResilientFunctions.Helpers;
34
using Cleipnir.ResilientFunctions.Messaging;
@@ -126,7 +127,7 @@ await Should.ThrowAsync<FatalWorkflowException<TimeoutException>>(() =>
126127
controlPanel.Status.ShouldBe(Status.Failed);
127128

128129
FailingUnitActionFlow.ShouldThrow = false;
129-
await controlPanel.Restart();
130+
await controlPanel.ScheduleRestart().Completion();
130131

131132
await controlPanel.Refresh();
132133
controlPanel.Status.ShouldBe(Status.Succeeded);
@@ -176,7 +177,7 @@ await Should.ThrowAsync<FatalWorkflowException<TimeoutException>>(() =>
176177
controlPanel.Status.ShouldBe(Status.Failed);
177178

178179
FailingUnitFuncFlow.ShouldThrow = false;
179-
await controlPanel.Restart();
180+
await controlPanel.ScheduleRestart().Completion();
180181

181182
await controlPanel.Refresh();
182183
controlPanel.Status.ShouldBe(Status.Succeeded);
@@ -226,7 +227,7 @@ await Should.ThrowAsync<FatalWorkflowException<TimeoutException>>(() =>
226227
controlPanel.Status.ShouldBe(Status.Failed);
227228

228229
FailingUnitParamlessFlow.ShouldThrow = false;
229-
await controlPanel.Restart();
230+
await controlPanel.ScheduleRestart().Completion();
230231

231232
await controlPanel.Refresh();
232233
controlPanel.Status.ShouldBe(Status.Succeeded);

Samples/Cleipnir.Sample.Presentation.AspNet/Controllers/OrderController.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
using Cleipnir.Flows.Sample.MicrosoftOpen.Clients;
22
using Cleipnir.Flows.Sample.MicrosoftOpen.Flows;
33
using Cleipnir.Flows.Sample.MicrosoftOpen.Flows.Rpc.Solution;
4+
using Cleipnir.ResilientFunctions;
45
using Microsoft.AspNetCore.Mvc;
56
using Serilog;
67
using ILogger = Serilog.ILogger;
@@ -36,7 +37,7 @@ public async Task<ActionResult> Post(string orderNumber, string? trackAndTraceNu
3637
else
3738
await controlPanel.Effects.SetSucceeded(shipProductsEffectId, new TrackAndTrace(trackAndTraceNumber));
3839

39-
await controlPanel.Restart();
40+
await controlPanel.ScheduleRestart().Completion();
4041
return Ok();
4142
}
4243

Samples/Cleipnir.Samples.Console/RestartFlow/Example.cs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Cleipnir.ResilientFunctions.Storage;
1+
using Cleipnir.ResilientFunctions;
2+
using Cleipnir.ResilientFunctions.Storage;
23
using Microsoft.Extensions.DependencyInjection;
34

45
namespace Cleipnir.Flows.Sample.ConsoleApp.RestartFlow;
@@ -29,6 +30,6 @@ public static async Task Do()
2930

3031
var controlPanel = await flows.ControlPanel(flowId);
3132
controlPanel!.Param = "valid parameter";
32-
await controlPanel.Restart();
33+
await controlPanel.ScheduleRestart().Completion();
3334
}
3435
}

0 commit comments

Comments
 (0)