From 5b0b73ec69add24a77126e48a855398aafe1a7fc Mon Sep 17 00:00:00 2001 From: Shivam Kumar Date: Sat, 27 Jan 2024 12:01:02 +0530 Subject: [PATCH] modify wf/activity completed logs Signed-off-by: Shivam Kumar --- pkg/runtime/wfengine/backends/actors/activity_actor.go | 2 +- pkg/runtime/wfengine/backends/actors/workflow_actor.go | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/runtime/wfengine/backends/actors/activity_actor.go b/pkg/runtime/wfengine/backends/actors/activity_actor.go index 0c154635129..499899cd32b 100644 --- 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 index 5ecb33f4f18..b8338b54f9b 100644 --- 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 }