17
req *historyservice.VerifyFirstWorkflowTaskScheduledRequest,
18
workflowConsistencyChecker api.WorkflowConsistencyChecker,
19
>
) (retError error) {
api.go
20
>
namespaceID := namespace.ID(req.GetNamespaceId())
21
>
if err := api.ValidateNamespaceUUID(namespaceID); err != nil {
22
return err
23
}
24
25
>
workflowLease, err := workflowConsistencyChecker.GetWorkflowLease(
api.go
26
>
ctx,
27
>
req.Clock,
28
>
definition.NewWorkflowKey(
29
>
req.NamespaceId,
30
>
req.WorkflowExecution.WorkflowId,
31
>
req.WorkflowExecution.RunId,
32
>
),
33
>
locks.PriorityLow,
34
>
)
35
>
if err != nil {
36
return err
37
}