modify log

Signed-off-by: MregXN <mregxn@gmail.com>
dapr · Dec 9, 2023 · c08017e · c08017e
1 parent 1578c53
commit c08017e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/examples/Workflow/WorkflowFanOutFanIn/Program.cs b/examples/Workflow/WorkflowFanOutFanIn/Program.cs
@@ -38,6 +38,7 @@
 
 using (daprClient)
 {
+    Console.WriteLine($"Workflow Started.");
     await daprClient.WaitForSidecarAsync();
 
     string instanceId = $"demo-workflow-{Guid.NewGuid().ToString()[..8]}";
@@ -51,4 +52,9 @@ await daprClient.StartWorkflowAsync(
     await daprClient.WaitForWorkflowCompletionAsync(
         workflowComponent: DaprWorkflowComponent,
         instanceId: instanceId);
+
+    GetWorkflowResponse state = await daprClient.GetWorkflowAsync(
+    instanceId: instanceId,
+    workflowComponent: DaprWorkflowComponent);
+    Console.WriteLine($"Workflow state: {state.RuntimeStatus}");
 }
diff --git a/examples/Workflow/WorkflowFanOutFanIn/Workflows/DemoWorkflow.cs b/examples/Workflow/WorkflowFanOutFanIn/Workflows/DemoWorkflow.cs
@@ -7,14 +7,11 @@ public class DemoWorkflow : Workflow<string, string>
     {
         public override async Task<string> RunAsync(WorkflowContext context, string input)
         {
-            Console.WriteLine("Workflow Started.");
-
             Task t1 = context.CallActivityAsync(nameof(NotifyActivity), "calling task 1 ...");
             Task t2 = context.CallActivityAsync(nameof(NotifyActivity), "calling task 2 ...");
             Task t3 = context.CallActivityAsync(nameof(NotifyActivity), "calling task 3 ...");
             await Task.WhenAll(t1, t2, t3);
 
-            Console.WriteLine("Workflow Completed.");
             return "Workflow Completed.";
         }
     }