29
request *historyservice.VerifyChildExecutionCompletionRecordedRequest,
30
) (versionedTransition *persistencespb.VersionedTransition,
32
>
workflowLease, err := workflowConsistencyChecker.GetWorkflowLease(
33
>
ctx,
34
>
request.Clock,
35
>
// it's ok we have stale state when doing verification,
36
>
// the logic will return WorkflowNotReady error and the caller will retry
37
>
// this can prevent keep reloading mutable state when there's a replication lag
38
>
// in parent shard.
39
>
definition.NewWorkflowKey(
40
>
request.NamespaceId,
41
>
request.ParentExecution.WorkflowId,
42
>
request.ParentExecution.RunId,
43
>
),
44
>
locks.PriorityLow,
45
>
)
46
>
if err != nil {
47
return nil, nil, err
48
}