go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-27 16:13:40 +08:00
Code Issues Projects Releases Wiki Activity

Minor fix

Browse Source
This commit is contained in:
Ken Hibino 2020-08-10 06:13:06 -07:00
parent 8e23b865e9
commit 4b81b91d3e
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/rdb/rdb.go
View File

@ -56,8 +56,7 @@ func (r *RDB) Enqueue(msg *base.TaskMessage) error {
if err != nil { if err != nil {
return err return err
} }
err := r.client.SAdd(base.AllQueues, msg.Queue).Err() if err := r.client.SAdd(base.AllQueues, msg.Queue).Err(); err != nil {
if err != nil {
return err return err
} }
key := base.QueueKey(msg.Queue) key := base.QueueKey(msg.Queue)
@ -85,8 +84,7 @@ func (r *RDB) EnqueueUnique(msg *base.TaskMessage, ttl time.Duration) error {
if err != nil { if err != nil {
return err return err
} }
err := r.client.SAdd(base.AllQueues, msg.Queue).Err() if err := r.client.SAdd(base.AllQueues, msg.Queue).Err(); err != nil {
if err != nil {
return err return err
} }
res, err := enqueueUniqueCmd.Run(r.client, res, err := enqueueUniqueCmd.Run(r.client,
@ -258,8 +256,7 @@ func (r *RDB) Schedule(msg *base.TaskMessage, processAt time.Time) error {
if err != nil { if err != nil {
return err return err
} }
err := r.client.SAdd(base.AllQueues, msg.Queue).Err() if err := r.client.SAdd(base.AllQueues, msg.Queue).Err(); err != nil {
if err != nil {
return err return err
} }
score := float64(processAt.Unix()) score := float64(processAt.Unix())
@ -288,8 +285,7 @@ func (r *RDB) ScheduleUnique(msg *base.TaskMessage, processAt time.Time, ttl tim
if err != nil { if err != nil {
return err return err
} }
err := r.client.SAdd(base.AllQueues, msg.Queue).Err() if err := r.client.SAdd(base.AllQueues, msg.Queue).Err(); err != nil {
if err != nil {
return err return err
} }
score := float64(processAt.Unix()) score := float64(processAt.Unix())