fix TestBackoff

ozontech · Jan 31, 2024 · 94fb9c3 · 94fb9c3
1 parent 0e86e09
commit 94fb9c3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pipeline/backoff_test.go b/pipeline/backoff_test.go
@@ -23,7 +23,7 @@ func TestBackoff(t *testing.T) {
 
 	batcherBackoff := NewRetriableBatcher(
 		&BatcherOptions{
-			MetricCtl: metric.New("", prometheus.NewRegistry()),
+			MetricCtl: metric.NewCtl("", prometheus.NewRegistry()),
 		},
 		func(workerData *WorkerData, batch *Batch) error {
 			eventCount.Inc()
@@ -48,7 +48,7 @@ func TestBackoffWithError(t *testing.T) {
 
 	batcherBackoff := NewRetriableBatcher(
 		&BatcherOptions{
-			MetricCtl: metric.New("", prometheus.NewRegistry()),
+			MetricCtl: metric.NewCtl("", prometheus.NewRegistry()),
 		},
 		func(workerData *WorkerData, batch *Batch) error {
 			return errors.New("some error")