Merge pull request #24 from SberMarket-Tech/remove-old-logger

Remove old Logger
Kuper-Tech · Feb 1, 2024 · 740239f · 740239f
2 parents 32872e7 + 36ac0bc
commit 740239f
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 7 deletions.
diff --git 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
@@ -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
@@ -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"