fixup! chore: emit metrics using transformer response headers. TODO: …

…cleanup
rudderlabs · Jan 28, 2025 · 628b601 · 628b601
1 parent 2d55fc4
commit 628b601
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/processor/transformer/transformer.go b/processor/transformer/transformer.go
@@ -522,9 +522,9 @@ func (trans *handle) doPost(ctx context.Context, rawJSON []byte, url, stage stri
 				newTags["instanceWorker"] = instanceWorker
 				trans.stat.NewTaggedStat("processor_transformer_instance_event_count", stats.CountType, newTags).Count(numEvents)
 				dur := time.Since(requestStartTime).Milliseconds()
-				headerTime, err := strconv.Atoi(headerResponseTime)
+				headerTime, err := strconv.ParseFloat(strings.TrimSuffix(headerResponseTime, "ms"), 64)
 				if err == nil {
-					diff := dur - int64(headerTime)
+					diff := float64(dur) - headerTime
 					trans.stat.NewTaggedStat("processor_tranform_duration_diff_time", stats.TimerType, newTags).SendTiming(time.Duration(diff) * time.Millisecond)
 				}
 			}