From d6a47dd675eb7321758caed6f70380105fec3dce Mon Sep 17 00:00:00 2001 From: laniehei Date: Wed, 4 Dec 2024 16:33:08 -0800 Subject: [PATCH] Add target cluster to error messaging --- service/worker/migration/activities.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/service/worker/migration/activities.go b/service/worker/migration/activities.go index af1688fd177..c2c6db10c19 100644 --- a/service/worker/migration/activities.go +++ b/service/worker/migration/activities.go @@ -778,10 +778,11 @@ func (a *activities) VerifyReplicationTasks(ctx context.Context, request *verify if diff > defaultNoProgressNotRetryableTimeout { // Potentially encountered a missing execution, return non-retryable error return response, temporal.NewNonRetryableApplicationError( - fmt.Sprintf("verifyReplicationTasks was not able to make progress for more than %v minutes (not retryable). Not found WorkflowExecution: %v, Checkpoint: %v", + fmt.Sprintf("verifyReplicationTasks was not able to make progress for more than %v minutes (not retryable): could not find WorkflowExecution: '%v' in TargetCluster: '%s': Checkpoint: '%v', ", diff.Minutes(), - details.LastNotVerifiedWorkflowExecution, details.CheckPoint), - "", nil) + details.LastNotVerifiedWorkflowExecution, request.TargetClusterName, details.CheckPoint), + "", + nil) } } }