Don't log error when job exists

engine/engine.go

@@ -1,9 +1,12 @@
 package engine
 
 import (
+	"errors"
 	"io"
 )
 
+var ErrJobExisted = errors.New("job existed")
+
 type Engine interface {
 	Publish(job Job) (jobID string, err error)
 	Consume(namespace string, queues []string, ttrSecond, timeoutSecond uint32) (job Job, err error)

engine/redis_v2/pool.go

@@ -1,7 +1,6 @@
 package redis_v2
 
 import (
-	"errors"
 	"time"
 
 	go_redis "github.com/go-redis/redis/v8"
@@ -47,7 +46,7 @@ func (p *Pool) Add(j engine.Job) error {
 		return err
 	}
 	if !ok {
-		return errors.New("key existed") // Key existed before, avoid overwriting it, so return error
+		return engine.ErrJobExisted // Key existed before, avoid overwriting it, so return error
 	}
 	return err
 }

storage/manager.go

@@ -116,7 +116,7 @@ func (m *Manager) PumpFn(name string, pool engine.Engine, threshold int64) func(
 		jobsID := make([]string, 0)
 		for _, job := range jobs {
 			_, err = pool.Publish(job)
-			if err != nil {
+			if err != nil && !errors.Is(err, engine.ErrJobExisted) {
 				logger.WithFields(logrus.Fields{
 					"job": job,
 					"err": err,