Fix task rescheduler metric scope (#2943)

temporalio · Jun 3, 2022 · dfbcdce · dfbcdce
1 parent c3d172d
commit dfbcdce
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/service/history/timerQueueStandbyProcessor.go b/service/history/timerQueueStandbyProcessor.go
@@ -123,7 +123,7 @@ func newTimerQueueStandbyProcessor(
 	rescheduler := queues.NewRescheduler(
 		scheduler,
 		shard.GetTimeSource(),
-		metricsClient.Scope(metrics.TimerActiveQueueProcessorScope),
+		metricsClient.Scope(metrics.TimerStandbyQueueProcessorScope),
 	)
 
 	timerQueueAckMgr := newTimerQueueAckMgr(

diff --git a/service/history/transferQueueActiveProcessor.go b/service/history/transferQueueActiveProcessor.go
@@ -123,7 +123,7 @@ func newTransferQueueActiveProcessor(
 	rescheduler := queues.NewRescheduler(
 		scheduler,
 		shard.GetTimeSource(),
-		shard.GetMetricsClient().Scope(metrics.TimerActiveQueueProcessorScope),
+		shard.GetMetricsClient().Scope(metrics.TransferActiveQueueProcessorScope),
 	)
 
 	transferTaskFilter := func(task tasks.Task) bool {
@@ -314,7 +314,7 @@ func newTransferQueueFailoverProcessor(
 	rescheduler := queues.NewRescheduler(
 		scheduler,
 		shard.GetTimeSource(),
-		shard.GetMetricsClient().Scope(metrics.TimerActiveQueueProcessorScope),
+		shard.GetMetricsClient().Scope(metrics.TransferActiveQueueProcessorScope),
 	)
 
 	queueAckMgr := newQueueFailoverAckMgr(