modify wf/activity completed logs

Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>
dapr · Jan 27, 2024 · 5b0b73e · 5b0b73e
1 parent c53fc16
commit 5b0b73e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/pkg/runtime/wfengine/backends/actors/activity_actor.go b/pkg/runtime/wfengine/backends/actors/activity_actor.go
@@ -241,7 +241,7 @@ loop:
 			}
 		}
 	}
-	wfLogger.Debugf("Activity actor '%s': activity '%s' completed for workflow with instanceId '%s' ", a.actorID, name, wi.InstanceID)
+	wfLogger.Debugf("Activity actor '%s': activity completed for workflow with instanceId '%s' activityName '%s'", a.actorID, wi.InstanceID, name)
 
 	// publish the result back to the workflow actor as a new event to be processed
 	resultData, err := backend.MarshalHistoryEvent(wi.Result)

diff --git a/pkg/runtime/wfengine/backends/actors/workflow_actor.go b/pkg/runtime/wfengine/backends/actors/workflow_actor.go
@@ -660,6 +660,9 @@ func (wf *workflowActor) runWorkflow(ctx context.Context, reminder actors.Intern
 			}
 		}
 	}
+	if runtimeState.IsCompleted() {
+		wfLogger.Infof("Workflow Actor '%s': workflow completed with status: '%s' workflowName: '%s'", wf.actorID, runtimeState.RuntimeStatus().String(), workflowName)
+	}
 	return nil
 }