diff --git a/processor/processor.go b/processor/processor.go index fc60541960f..fc677829af9 100644 --- a/processor/processor.go +++ b/processor/processor.go @@ -140,8 +140,6 @@ type Handle struct { eventSchemaV2Enabled bool archivalEnabled misc.ValueLoader[bool] eventAuditEnabled map[string]bool - - toAbortJobRunIDs misc.ValueLoader[string] } adaptiveLimit func(int64) int64 diff --git a/processor/processor_test.go b/processor/processor_test.go index 3b1b35e090b..1af4389b32c 100644 --- a/processor/processor_test.go +++ b/processor/processor_test.go @@ -3547,7 +3547,6 @@ var _ = Describe("Static Function Tests", func() { } response := ConvertToFilteredTransformerResponse(events, true) Expect(response).To(Equal(expectedResponse)) - }) }) }) diff --git a/router/router_test.go b/router/router_test.go index 5c578c5dfbe..3dc10684896 100644 --- a/router/router_test.go +++ b/router/router_test.go @@ -679,7 +679,6 @@ var _ = Describe("router", func() { Expect(worker.Work()).To(BeTrue()) Expect(worker.pickupCount).To(Equal(len(unprocessedJobsList))) Eventually(func() bool { return routerAborted && procErrorStored }, 5*time.Second, 100*time.Millisecond).Should(Equal(true)) - }) It("aborts events that have reached max retries", func() {