Skip to content

Commit 7af867a

Browse files
committed
use mockable time
1 parent c3baff8 commit 7af867a

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

enqueue.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package work
22

33
import (
44
"sync"
5-
"time"
65

76
"github.com/gomodule/redigo/redis"
87
)
@@ -153,7 +152,7 @@ func (e *Enqueuer) EnqueueUniqueInByKey(jobName string, secondsFromNow int64, ar
153152

154153
func (e *Enqueuer) addToKnownJobs(conn redis.Conn, jobName string) error {
155154
needSadd := true
156-
now := time.Now().Unix()
155+
now := nowEpochSeconds()
157156

158157
e.mtx.RLock()
159158
t, ok := e.knownJobs[jobName]

0 commit comments

Comments
 (0)