725
}
726
727
>
isMember, shouldSkipReactivation, revisionNumber, err := checkVersionMembershipAndReactivationEligibility(ctx, matchingClient, namespaceID, tq, tqType, pinnedVersion)
worker_versioning.go
728
>
if err != nil {
729
return false, 0, err
730
}
731
732
// Add result to cache
734
>
namespaceID,
735
>
tq,
736
>
tqType,
737
>
pinnedVersion.DeploymentName,
738
>
pinnedVersion.BuildId,
739
>
isMember,
740
>
shouldSkipReactivation,
741
>
revisionNumber,
742
>
)
743
>
if !isMember {
744
return false, 0, serviceerror.NewFailedPrecondition(
745
FormatPinnedVersionNotInTaskQueueError(pinnedVersion.GetDeploymentName(), pinnedVersion.GetBuildId(), tq, tqType),