diff --git a/dead_pool_reaper.go b/dead_pool_reaper.go
index cc5603e5..fce6d5f2 100644
--- a/dead_pool_reaper.go
+++ b/dead_pool_reaper.go
@@ -258,7 +258,7 @@ func (r *deadPoolReaper) cleanStaleLockInfo(poolID string, jobTypes []string) er
 		return err
 	}
 	if len(negativeLocks) > 0 {
-		Logger.Printf("Reaper: negative locks: %v", negativeLocks)
+		r.logger.Info("Reaper: negative locks", slog.Any("keys", negativeLocks))
 	}
 
 	return nil
diff --git a/worker_pool_test.go b/worker_pool_test.go
index 039bee43..742b28fd 100644
--- a/worker_pool_test.go
+++ b/worker_pool_test.go
@@ -4,7 +4,6 @@ import (
 	"bytes"
 	"context"
 	"fmt"
-	"log"
 	"reflect"
 	"testing"
 	"time"
@@ -227,8 +226,6 @@ func TestWorkerPoolTracing(t *testing.T) {
 	ctx, span := tp.Tracer("").Start(context.Background(), "enqueue")
 	span.End()
 
-	Logger = log.Default()
-
 	enqueuer := NewEnqueuer(ns, pool)
 
 	_, err := enqueuer.EnqueueContext(ctx, jobName, Q{"a": "b"})
diff --git a/worker_test.go b/worker_test.go
index edd52310..f63201cb 100644
--- a/worker_test.go
+++ b/worker_test.go
@@ -3,7 +3,6 @@ package work
 import (
 	"fmt"
 	"io"
-	"log"
 	"strconv"
 	"sync"
 	"sync/atomic"
@@ -636,8 +635,6 @@ func TestWorkerPoolStop(t *testing.T) {
 }
 
 func TestWorkerRetryRemoveFromInProgress(t *testing.T) {
-	Logger = log.Default()
-
 	originPool := newTestPool(":6379")
 	pool := newSwitchablePool(originPool)
 	ns := "work"