340
tqType enumspb.TaskQueueType,
341
version *deploymentpb.WorkerDeploymentVersion,
342
>
) (isMember bool, shouldSkipReactivation bool, revisionNumber int64, err error) {
worker_versioning.go
343
>
resp, err := matchingClient.CheckTaskQueueVersionMembership(ctx, &matchingservice.CheckTaskQueueVersionMembershipRequest{
344
>
NamespaceId: namespaceID,
345
>
TaskQueue: tq,
346
>
TaskQueueType: tqType,
347
>
Version: DeploymentVersionFromDeployment(DeploymentFromExternalDeploymentVersion(version)),
348
>
})
349
>
if err != nil {
350
// If matching is on an older version that doesn't have this RPC,
351
// fall back to fetching full user data and checking version membership based on the received information.