Use latest version of ResilientFunctions

stidsborg · Jul 14, 2024 · d89cd46 · d89cd46
1 parent 9309700
commit d89cd46
Show file tree

Hide file tree

Showing 7 changed files with 10 additions and 10 deletions.
diff --git a/Cleipnir.Flows.Tests/Flows/FlowsWithResultTests.cs b/Cleipnir.Flows.Tests/Flows/FlowsWithResultTests.cs
@@ -45,7 +45,7 @@ public override async Task<int> Run(string param)
         {
             await Task.Delay(1);
             ExecutedWithParameter = param;
-            InstanceId = Workflow.FunctionId.InstanceId.ToString();
+            InstanceId = Workflow.FlowId.Instance.ToString();
 
             return 1;
         }
@@ -119,7 +119,7 @@ await Should.ThrowAsync<ArgumentException>(() =>
         controlPanel.Status.ShouldBe(Status.Failed);
 
         FailingFuncFlow.ShouldThrow = false;
-        await controlPanel.ReInvoke();
+        await controlPanel.Restart();
 
         await controlPanel.Refresh();
         controlPanel.Status.ShouldBe(Status.Succeeded);

diff --git a/Cleipnir.Flows.Tests/Flows/OptionsTests.cs b/Cleipnir.Flows.Tests/Flows/OptionsTests.cs
@@ -85,7 +85,7 @@ public async Task FlowNameCanBeSpecifiedFromTheOutside()
         var flows = sp.GetRequiredService<SimpleFlows>();
         await flows.Run("Id");
         var store = sp.GetRequiredService<IFunctionStore>();
-        var sf = await store.GetFunction(new FunctionId("SomeOtherFlowName", "Id"));
+        var sf = await store.GetFunction(new FlowId("SomeOtherFlowName", "Id"));
         sf.ShouldNotBeNull();
         sf.Status.ShouldBe(Status.Succeeded);
     }

diff --git a/Cleipnir.Flows.Tests/Flows/ParamlessFlowsTests.cs b/Cleipnir.Flows.Tests/Flows/ParamlessFlowsTests.cs
@@ -39,7 +39,7 @@ public class SimpleParamlessFlow : Flow
         public override async Task Run()
         {
             await Task.Delay(1);
-            InstanceId = Workflow.FunctionId.InstanceId.ToString();
+            InstanceId = Workflow.FlowId.Instance.ToString();
         }
     }
 
@@ -109,7 +109,7 @@ await Should.ThrowAsync<TimeoutException>(() =>
         controlPanel.Status.ShouldBe(Status.Failed);
 
         FailingParamlessFlow.ShouldThrow = false;
-        await controlPanel.ReInvoke();
+        await controlPanel.Restart();
 
         await controlPanel.Refresh();
         controlPanel.Status.ShouldBe(Status.Succeeded);

diff --git a/Cleipnir.Flows.Tests/Flows/UnitFlowsTests.cs b/Cleipnir.Flows.Tests/Flows/UnitFlowsTests.cs
@@ -42,7 +42,7 @@ public override async Task Run(string param)
         {
             await Task.Delay(1);
             ExecutedWithParameter = param;
-            InstanceId = Workflow.FunctionId.InstanceId.ToString();
+            InstanceId = Workflow.FlowId.Instance.ToString();
         }
     }
 
@@ -112,7 +112,7 @@ await Should.ThrowAsync<TimeoutException>(() =>
         controlPanel.Status.ShouldBe(Status.Failed);
 
         FailingUnitFlow.ShouldThrow = false;
-        await controlPanel.ReInvoke();
+        await controlPanel.Restart();
 
         await controlPanel.Refresh();
         controlPanel.Status.ShouldBe(Status.Succeeded);

diff --git a/Cleipnir.ResilientFunctions b/Cleipnir.ResilientFunctions
diff --git a/Samples/Cleipnir.Flows.Sample.MicrosoftOpen/Controllers/OrderController.cs b/Samples/Cleipnir.Flows.Sample.MicrosoftOpen/Controllers/OrderController.cs
@@ -36,7 +36,7 @@ public async Task<ActionResult> Post(string orderNumber)
             return NotFound();
 
         await controlPanel.Effects.Remove("ShipProducts");
-        await controlPanel.ReInvoke();
+        await controlPanel.Restart();
 
         return Ok();
     }

diff --git a/Samples/Cleipnir.Flows.Samples.Console/RestartFlow/Example.cs b/Samples/Cleipnir.Flows.Samples.Console/RestartFlow/Example.cs
@@ -29,6 +29,6 @@ public static async Task Do()
 
         var controlPanel = await flows.ControlPanel(flowId);
         controlPanel!.Param = "valid parameter";
-        await controlPanel.ReInvoke();
+        await controlPanel.Restart();
     }
 }