1075
diff := time.Since(details.CheckPoint)
1076
if diff > defaultNoProgressNotRetryableTimeout {
1077
>
// Potentially encountered a missing execution, return non-retryable error
activities.go
1078
>
return response, temporal.NewNonRetryableApplicationError(
1079
>
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', ",
1080
>
diff.Minutes(),
1081
>
details.LastNotVerifiedWorkflowExecution, request.TargetClusterName, details.CheckPoint),
1082
>
"",
1083
>
nil)
1084
>
}
1085
}
1086
}