init tagged metrics handler

Author: yux0

service/history/queues/executable.go

@@ -206,7 +206,7 @@ func (e *executableImpl) Execute() (retErr error) {
 		// emit total attempt latency so that we know how much time a task will occpy a worker goroutine
 		e.taggedMetricsHandler.Timer(metrics.TaskProcessingLatency.GetMetricName()).Record(attemptLatency)
 
-		priorityTaggedProvider := e.taggedMetricsHandler.WithTags(metrics.TaskPriorityTag(e.priority.String()))
+		priorityTaggedProvider := e.taggedMetricsHandler.WithTags(metrics.TaskPriorityTag(executablePriority.String()))
 		priorityTaggedProvider.Counter(metrics.TaskRequests.GetMetricName()).Record(1)
 		priorityTaggedProvider.Timer(metrics.TaskScheduleLatency.GetMetricName()).Record(e.scheduleLatency)
 
@@ -219,6 +219,7 @@ func (e *executableImpl) Execute() (retErr error) {
 
 	ns, err := e.namespaceRegistry.GetNamespaceByID(namespace.ID(e.GetNamespaceID()))
 	if err != nil {
+		e.taggedMetricsHandler = e.metricsHandler.WithTags(e.estimateTaskMetricTag()...)
 		return err
 	}
 	var callerInfo headers.CallerInfo
@@ -233,6 +234,7 @@ func (e *executableImpl) Execute() (retErr error) {
 
 	if !ns.IsOnCluster(e.clusterMetadata.GetCurrentClusterName()) {
 		// Discard task if the namespace is not on the current cluster.
+		e.taggedMetricsHandler = e.metricsHandler.WithTags(e.estimateTaskMetricTag()...)
 		return consts.ErrTaskDiscarded
 	}