Fix NDC metrics reporting (#1216)

temporalio · Jan 23, 2021 · f6225de · f6225de
1 parent 95c1b5b
commit f6225de
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/service/history/replicatorQueueProcessor.go b/service/history/replicatorQueueProcessor.go
@@ -142,8 +142,10 @@ func (p *replicatorQueueProcessorImpl) getTasks(
 	}
 
 	// Note this is a very rough indicator of how much the remote DC is behind on this shard.
-	p.metricsClient.RecordTimer(
+	p.metricsClient.Scope(
 		metrics.ReplicatorQueueProcessorScope,
+		metrics.TargetClusterTag(pollingCluster),
+	).RecordTimer(
 		metrics.ReplicationTasksLag,
 		time.Duration(p.shard.GetTransferMaxReadLevel()-readLevel),
 	)