35
}
36
37
>
req := request.Request
api.go
38
>
execution := req.Execution
39
>
var pageToken *tokenspb.RawHistoryContinuation
40
>
var targetVersionHistory *historyspb.VersionHistory
41
>
if req.NextPageToken == nil {
42
>
response, err := api.GetOrPollWorkflowMutableState(
43
>
ctx,
44
>
shardContext,
45
>
&historyservice.GetMutableStateRequest{
46
>
NamespaceId: ns.ID().String(),
47
>
Execution: execution,
48
>
},
49
>
workflowConsistencyChecker,
50
>
eventNotifier,
51
>
)
52
>
if err != nil {
53
return nil, err
54
}