fixup! chore: update processor logic to accomodate jobRunID aborts

rudderlabs · Oct 6, 2023 · 2bcf64c · 2bcf64c
1 parent 90fdddf
commit 2bcf64c
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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() {