fixup! chore: minor processor cleanup

rudderlabs · Oct 11, 2023 · ccc10c2 · ccc10c2
1 parent 4b6979c
commit ccc10c2
Showing 1 changed file with 11 additions and 4 deletions.
diff --git 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))