return max(1, config.NumTaskqueueWritePartitions(ns.String(), taskQueueName, taskType))
},
return max(1, config.NumTaskqueueReadPartitions(ns.String(), taskQueueName, taskType))
},
NumReadPartitionsSub: func(cb func(int)) (int, func()) {
return config.NumTaskqueueReadPartitionsSub(ns.String(), taskQueueName, taskType, cb)