emit domain specific metrics in task processing

cadence-workflow · May 26, 2020 · af5440b · af5440b
1 parent 29c9164
commit af5440b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/service/history/taskProcessor.go b/service/history/taskProcessor.go
@@ -246,7 +246,7 @@ func (t *taskProcessor) processTaskOnce(
 
 	startTime := t.timeSource.Now()
 	scopeIdx, err := task.processor.process(task)
-	scope := t.metricsClient.Scope(scopeIdx)
+	scope := t.metricsClient.Scope(scopeIdx).Tagged(t.getDomainTagByID(task.task.GetDomainID()))
 	if task.shouldProcessTask {
 		scope.IncCounter(metrics.TaskRequests)
 		scope.RecordTimer(metrics.TaskProcessingLatency, time.Since(startTime))