546
partition tqid.Partition,
547
tqConfig *taskQueueConfig,
549
>
nsName := nsEntry.Name().String()
550
>
var nsState string
551
>
//nolint:forbidigo // metric tag for namespace state, not per-workflow
552
>
if nsEntry.ActiveInCluster(e.clusterMeta.GetCurrentClusterName()) {
553
>
nsState = metrics.ActiveNamespaceStateTagValue
554
>
} else {
555
nsState = metrics.PassiveNamespaceStateTagValue
556
}
558
>
tag.WorkflowTaskQueueName(partition.RpcName()),
559
>
tag.WorkflowTaskQueueType(partition.TaskType()),
560
>
tag.WorkflowNamespace(nsName))
561
>
throttledLogger := log.With(e.throttledLogger,
562
>
tag.WorkflowTaskQueueName(partition.RpcName()),
563
>
tag.WorkflowTaskQueueType(partition.TaskType()),
564
>
tag.WorkflowNamespace(nsName))
565
>
metricsHandler := metrics.GetPerTaskQueuePartitionIDScope(
566
>
e.metricsHandler,
567
>
nsName,
568
>
partition,
569
>
tqConfig.BreakdownMetricsByTaskQueue(),
570
>
tqConfig.BreakdownMetricsByPartition(),
571
>
metrics.OperationTag(metrics.MatchingTaskQueuePartitionManagerScope),
572
>
).WithTags(metrics.NamespaceStateTag(nsState))
573
>
return logger, throttledLogger, metricsHandler
574
}
575