From 7f620f52fe074e217730b6e66380e6395b62b134 Mon Sep 17 00:00:00 2001
From: Raman Khatri <raman2805@gmail.com>
Date: Wed, 2 Nov 2022 20:45:17 +0530
Subject: [PATCH] chore: add source to event_delivery metric

---
 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 bb42a657b8..82cf8db7ce 100644
--- a/router/batchrouter/batchrouter.go
+++ b/router/batchrouter/batchrouter.go
@@ -1577,6 +1577,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 62697d36b3..2f8d67cb99 100644
--- a/router/router.go
+++ b/router/router.go
@@ -1186,6 +1186,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 != "" {