fix: dedup duration stat name fix

rudderlabs · Oct 29, 2024 · 5ff3872 · 5ff3872
1 parent 93ee8db
commit 5ff3872
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/processor/processor.go b/processor/processor.go
@@ -1816,7 +1816,7 @@ func (proc *Handle) processJobsForDestV2(partition string, subJobs subJob) (*tra
 			return nil, err
 		}
 	}
-	proc.statsFactory.NewStat("processor.event_pickup_lag_seconds", stats.TimerType).Since(dedupStart)
+	proc.statsFactory.NewTaggedStat("processor.dedup_duration_seconds", stats.TimerType, stats.Tags{"process": "V2"}).Since(dedupStart)
 	for _, event := range jobsWithMetaData {
 		sourceId := event.eventParams.SourceId
 		if event.eventParams.DestinationID != "" {