exit code 137

temporalio · Mar 30, 2024 · ce8a6d3 · ce8a6d3
1 parent c15d314
commit ce8a6d3
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/src/SignalsQueries/LoyaltyProgram.workflow.cs b/src/SignalsQueries/LoyaltyProgram.workflow.cs
@@ -28,10 +28,10 @@ public async Task NotifyPurchaseAsync(int purchaseTotalCents)
 
         if (Points >= 10_000)
         {
+            Points -= 10_000;
             await Workflow.ExecuteActivityAsync(
                 () => MyActivities.SendCoupon(userId),
                 new() { ScheduleToCloseTimeout = TimeSpan.FromMinutes(5) });
-            Points -= 10_000;
         }
     }
 }
diff --git a/src/SignalsQueries/MyActivities.cs b/src/SignalsQueries/MyActivities.cs
@@ -1,5 +1,6 @@
 namespace TemporalioSamples.SignalsQueries;
 
+using Microsoft.Extensions.Logging;
 using Temporalio.Activities;
 
 public class MyActivities

diff --git a/src/SignalsQueries/Program.cs b/src/SignalsQueries/Program.cs
@@ -41,6 +41,9 @@ async Task RunWorkerAsync()
 
 async Task ExecuteWorkflowAsync()
 {
+    // If the workflow is already running from a previous run, terminate it
+    await client.GetWorkflowHandle("signals-queries-workflow-id").TerminateAsync();
+
     Console.WriteLine("Executing workflow");
     var handle = await client.StartWorkflowAsync(
         (LoyaltyProgram wf) => wf.RunAsync("user-id-123"),
@@ -52,7 +55,7 @@ async Task ExecuteWorkflowAsync()
     await handle.SignalAsync(wf => wf.NotifyPurchaseAsync(3_000));
 
     var points = await handle.QueryAsync(wf => wf.Points);
-    Console.WriteLine("Remaining points: {Points}", points);
+    Console.WriteLine("Remaining points: {0}", points);
 }
 
 switch (args.ElementAtOrDefault(0))