44
45
// IsInternalPerNsTaskQueue returns true if the task queue name belongs to a per-namespace internal system worker
46
>
func IsInternalPerNsTaskQueue(taskQueue string) bool {
task_queues.go
47
>
// TODO: remove WorkerControllerPerNSWorkerTaskQueue once it has been updated to match the prefix
48
>
return strings.HasPrefix(taskQueue, internalTaskQueuePerNSPrefix) || taskQueue == WorkerControllerPerNSWorkerTaskQueue
49
>
}
50
51
// CheckInternalPerNsTaskQueueAllowed tries to block the usage of internal per-namespace task queue for illegal cases.