still

temporalio · Mar 30, 2024 · 86477ec · 86477ec
1 parent 64d8186
commit 86477ec
Showing 1 changed file with 20 additions and 19 deletions.
diff --git a/src/SignalsQueries/Program.cs b/src/SignalsQueries/Program.cs
@@ -41,28 +41,29 @@ async Task RunWorkerAsync()
 
 async Task ExecuteWorkflowAsync()
 {
-    // If the workflow is already running from a previous run, terminate it
-    try
-    {
-        await client.GetWorkflowHandle("signals-queries-workflow-id").TerminateAsync();
-    }
-    catch
-    {
-        // Ignore
-    }
+    await Task.CompletedTask;
+    // // If the workflow is already running from a previous run, terminate it
+    // try
+    // {
+    //     await client.GetWorkflowHandle("signals-queries-workflow-id").TerminateAsync();
+    // }
+    // catch
+    // {
+    //     // Ignore
+    // }
 
-    Console.WriteLine("Executing workflow");
-    var handle = await client.StartWorkflowAsync(
-        (LoyaltyProgram wf) => wf.RunAsync("user-id-123"),
-        new(id: "signals-queries-workflow-id", taskQueue: "signals-queries-sample"));
+    // Console.WriteLine("Executing workflow");
+    // var handle = await client.StartWorkflowAsync(
+    //     (LoyaltyProgram wf) => wf.RunAsync("user-id-123"),
+    //     new(id: "signals-queries-workflow-id", taskQueue: "signals-queries-sample"));
 
-    Console.WriteLine("Signal: Purchase made for $80");
-    await handle.SignalAsync(wf => wf.NotifyPurchaseAsync(new Purchase("purchase-1", 8_000)));
-    Console.WriteLine("Signal: Purchase made for $30");
-    await handle.SignalAsync(wf => wf.NotifyPurchaseAsync(new Purchase("purchase-1", 3_000)));
+    // Console.WriteLine("Signal: Purchase made for $80");
+    // await handle.SignalAsync(wf => wf.NotifyPurchaseAsync(new Purchase("purchase-1", 8_000)));
+    // Console.WriteLine("Signal: Purchase made for $30");
+    // await handle.SignalAsync(wf => wf.NotifyPurchaseAsync(new Purchase("purchase-1", 3_000)));
 
-    var points = await handle.QueryAsync(wf => wf.Points);
-    Console.WriteLine("Remaining points: {0}", points);
+    // var points = await handle.QueryAsync(wf => wf.Points);
+    // Console.WriteLine("Remaining points: {0}", points);
 }
 
 switch (args.ElementAtOrDefault(0))