300
type IsWFTaskQueueInVersionDetector = func(ctx context.Context, namespaceID, tq string, version *deploymentpb.WorkerDeploymentVersion) (bool, error)
301
302
>
func GetIsWFTaskQueueInVersionDetector(matchingClient resource.MatchingClient, versionCache VersionMembershipAndReactivationStatusCache) IsWFTaskQueueInVersionDetector {
worker_versioning.go
303
>
return func(ctx context.Context,
304
>
namespaceID, tq string,
305
>
version *deploymentpb.WorkerDeploymentVersion) (bool, error) {
306
>
307
>
// Check cache first.
308
>
if isMember, _, _, ok := versionCache.Get(
309
>
namespaceID, tq, enumspb.TASK_QUEUE_TYPE_WORKFLOW,
310
>
version.GetDeploymentName(), version.GetBuildId(),
311
>
); ok {
312
return isMember, nil
313
}