fix build issue after rebase

cadence-workflow · Dec 28, 2023 · 911313b · 911313b
1 parent 4ccb876
commit 911313b
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 8 deletions.
diff --git a/service/history/queue/processor_base.go b/service/history/queue/processor_base.go
@@ -23,7 +23,6 @@ package queue
 import (
 	"context"
 	"fmt"
-	"strconv"
 	"sync"
 	"time"
 
@@ -95,7 +94,7 @@ func newProcessorBase(
 	logger log.Logger,
 	metricsClient metrics.Client,
 ) *processorBase {
-	metricsScope := metricsClient.Scope(options.MetricScope).Tagged(metrics.ShardIDTag(strconv.Itoa(shard.GetShardID())))
+	metricsScope := metricsClient.Scope(options.MetricScope).Tagged(metrics.ShardIDTag(shard.GetShardID()))
 	return &processorBase{
 		shard:         shard,
 		taskProcessor: taskProcessor,

diff --git a/service/history/queue/timer_queue_processor.go b/service/history/queue/timer_queue_processor.go
@@ -23,7 +23,6 @@ package queue
 import (
 	"context"
 	"fmt"
-	"strconv"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -433,7 +432,7 @@ func (t *timerQueueProcessor) completeTimer() error {
 
 	t.logger.Debugf("Start completing timer task from: %v, to %v", t.ackLevel, newAckLevelTimestamp)
 	t.metricsClient.Scope(metrics.TimerQueueProcessorScope).
-		Tagged(metrics.ShardIDTag(strconv.Itoa(t.shard.GetShardID()))).
+		Tagged(metrics.ShardIDTag(t.shard.GetShardID())).
 		IncCounter(metrics.TaskBatchCompleteCounter)
 
 	for {

diff --git a/service/history/queue/timer_queue_processor_base.go b/service/history/queue/timer_queue_processor_base.go
@@ -25,7 +25,6 @@ import (
 	"fmt"
 	"math"
 	"math/rand"
-	"strconv"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -543,7 +542,7 @@ func (t *timerQueueProcessorBase) notifyNewTimers(timerTasks []persistence.Task)
 
 	isActive := t.options.MetricScope == metrics.TimerActiveQueueProcessorScope
 	minNewTime := timerTasks[0].GetVisibilityTimestamp()
-	shardIDTag := metrics.ShardIDTag(strconv.Itoa(t.shard.GetShardID()))
+	shardIDTag := metrics.ShardIDTag(t.shard.GetShardID())
 	for _, timerTask := range timerTasks {
 		ts := timerTask.GetVisibilityTimestamp()
 		if ts.Before(minNewTime) {

diff --git a/service/history/queue/transfer_queue_processor.go b/service/history/queue/transfer_queue_processor.go
@@ -25,7 +25,6 @@ import (
 	"errors"
 	"fmt"
 	"math"
-	"strconv"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -425,7 +424,7 @@ func (t *transferQueueProcessor) completeTransfer() error {
 	}
 
 	t.metricsClient.Scope(metrics.TransferQueueProcessorScope).
-		Tagged(metrics.ShardIDTag(strconv.Itoa(t.shard.GetShardID()))).
+		Tagged(metrics.ShardIDTag(t.shard.GetShardID())).
 		IncCounter(metrics.TaskBatchCompleteCounter)
 
 	for {