From 7bba131f749ed1b0b5fef1dab01125d2412bcd47 Mon Sep 17 00:00:00 2001
From: Raman Khatri <raman2805@gmail.com>
Date: Wed, 9 Nov 2022 12:06:42 -0500
Subject: [PATCH] chore: add source to event_delivery metric (#2642)

---
 router/batchrouter/batchrouter.go | 1 +
 router/router.go                  | 1 +
 2 files changed, 2 insertions(+)

diff --git a/router/batchrouter/batchrouter.go b/router/batchrouter/batchrouter.go
index 07302f98d8..53e4f05d4b 100644
--- 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
index 0b774cf088..98d91d3682 100644
--- 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 != "" {