From ec560afb0167e146f763d1d2e7fbed4884f9eeb6 Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Wed, 16 Feb 2022 20:42:08 -0800 Subject: [PATCH] Fix processor test --- processor_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/processor_test.go b/processor_test.go index 83a7726..00f7ad6 100644 --- a/processor_test.go +++ b/processor_test.go @@ -540,6 +540,7 @@ func TestProcessorWithExpiredLease(t *testing.T) { p := newProcessor(processorParams{ logger: testLogger, broker: rdbClient, + baseCtxFn: context.Background, retryDelayFunc: DefaultRetryDelayFunc, isFailureFunc: defaultIsFailureFunc, syncCh: syncCh,