From ccc10c2ff358def4173778777fbe900bbf370ec0 Mon Sep 17 00:00:00 2001
From: "siddarth.msv" <siddarthmsv+1@gmail.com>
Date: Wed, 11 Oct 2023 20:56:07 +0530
Subject: [PATCH] fixup! chore: minor processor cleanup

---
 processor/processor_test.go | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/processor/processor_test.go b/processor/processor_test.go
index 6ace2d75b18..06daa86ccf7 100644
--- a/processor/processor_test.go
+++ b/processor/processor_test.go
@@ -2254,11 +2254,18 @@ var _ = Describe("Processor", Ordered, func() {
 			m := processor.getNonSuccessfulMetrics(transformerResponse,
 				&commonMetadata,
 				eventsByMessageID,
-				transformer.DestTransformerStage,
-				false,
-				false)
+				types.DEST_TRANSFORMER,
+				types.EVENT_FILTER,
+			)
 
-			key := fmt.Sprintf("%s!<<#>>!%s!<<#>>!%s!<<#>>!%s!<<#>>!%s", commonMetadata.SourceID, commonMetadata.DestinationID, commonMetadata.SourceJobRunID, commonMetadata.EventName, commonMetadata.EventType)
+			key := fmt.Sprintf(
+				"%s!<<#>>!%s!<<#>>!%s!<<#>>!%s!<<#>>!%s",
+				commonMetadata.SourceID,
+				commonMetadata.DestinationID,
+				commonMetadata.SourceJobRunID,
+				commonMetadata.EventName,
+				commonMetadata.EventType,
+			)
 
 			Expect(len(m.failedJobs)).To(Equal(2))
 			Expect(len(m.failedMetrics)).To(Equal(2))