1890
return nil, err
1891
}
1892
>
partition := family.TaskQueue(request.GetTaskQueueType()).NormalPartition(int(request.GetPartitionId()))
admin_handler.go
1893
>
1894
>
// Fetch the user data currently loaded by the target partition.
1895
>
// LastKnownUserDataVersion=0: no cached version, always return current data.
1896
>
// LastKnownEphemeralDataVersion=-1: skip ephemeral data; we only need persisted per-type data.
1897
>
resp, err := adh.matchingClient.GetTaskQueueUserData(ctx, &matchingservice.GetTaskQueueUserDataRequest{
1898
>
NamespaceId: namespaceID.String(),
1899
>
TaskQueue: partition.RpcName(),
1900
>
TaskQueueType: request.GetTaskQueueType(),
1901
>
LastKnownUserDataVersion: 0,
1902
>
LastKnownEphemeralDataVersion: -1,
1903
>
})
1904
>
if err != nil {
1905
return nil, err
1906
}