317
318
if !ok {
319
>
// Cache miss, fetch from matching
api.go
320
>
resp, err := matchingClient.GetTaskQueueUserData(ctx,
321
>
&matchingservice.GetTaskQueueUserDataRequest{
322
>
NamespaceId: namespaceID,
323
>
TaskQueue: taskQueueName,
324
>
TaskQueueType: taskQueueType,
325
>
})
326
>
if err != nil {
327
return nil, 0, err
328
}
329
>
tqData, ok := resp.GetUserData().GetData().GetPerType()[int32(taskQueueType)]
api.go
330
>
if ok {
331
// Calculate the routing info for versioned task queue
332
routingInfo.Current, routingInfo.CurrentRevisionNumber, _, routingInfo.Ramping, _, routingInfo.RampPercentage, routingInfo.RampingRevisionNumber, _ = worker_versioning.CalculateTaskQueueVersioningInfo(tqData.GetDeploymentData())