chore: add source to event_delivery metric (#2642)

rudderlabs · Nov 11, 2022 · 7bba131 · 7bba131
1 parent 129fb2e
commit 7bba131
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/router/batchrouter/batchrouter.go b/router/batchrouter/batchrouter.go
@@ -1585,6 +1585,7 @@ func (brt *HandleT) recordUploadStats(destination DestinationT, output StorageUp
 		"destType":    brt.destType,
 		"destination": destinationTag,
 		"workspaceId": destination.Source.WorkspaceID,
+		"source":      destination.Source.ID,
 	})
 	eventDeliveryStat.Count(output.TotalEvents)
 

diff --git a/router/router.go b/router/router.go
@@ -1157,6 +1157,7 @@ func (worker *workerT) sendEventDeliveryStat(destinationJobMetadata *types.JobMe
 			"destination":    destinationTag,
 			"attempt_number": strconv.Itoa(status.AttemptNum),
 			"workspaceId":    status.WorkspaceId,
+			"source":         destinationJobMetadata.SourceID,
 		})
 		eventsDeliveredStat.Count(1)
 		if destinationJobMetadata.ReceivedAt != "" {