707
tq string,
708
tqType enumspb.TaskQueueType,
709
>
namespaceID string) (shouldSkipReactivation bool, revisionNumber int64, err error) {
worker_versioning.go
710
>
711
>
// Check if we have recently queried matching to validate if this version exists in the task queue.
712
>
if isMember, cachedActiveOrDraining, cachedRevision, ok := versionCache.Get(
713
>
namespaceID,
714
>
tq,
715
>
tqType,
716
>
pinnedVersion.DeploymentName,
717
>
pinnedVersion.BuildId,
718
>
); ok {
719
if isMember {
720
return cachedActiveOrDraining, cachedRevision, nil