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,