From ac3190a0d590c5d98c59f616cb1766d155829815 Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Sat, 23 Nov 2019 16:44:22 -0800 Subject: [PATCH] Update comments --- asynq.go | 3 +-- rdb.go | 1 + 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/asynq.go b/asynq.go index 0601f38..2014174 100644 --- a/asynq.go +++ b/asynq.go @@ -5,9 +5,8 @@ import "github.com/google/uuid" /* TODOs: - [P0] Write tests -- [P0] Add heartbeats and rescuer - [P0] Make all moving operations atomic -- [P1] Add Support for multiple queues +- [P1] Add Support for multiple queues and priority - [P1] User defined max-retry count - [P2] Web UI */ diff --git a/rdb.go b/rdb.go index 3be97d5..c78ff16 100644 --- a/rdb.go +++ b/rdb.go @@ -124,6 +124,7 @@ func (r *rdb) zRangeByScore(key string, opt *redis.ZRangeBy) ([]*taskMessage, er // move moves taskMessage from zfrom to the specified queue. func (r *rdb) move(from string, msg *taskMessage) error { + // TODO(hibiken): Lua script, make this atomic. bytes, err := json.Marshal(msg) if err != nil { return errSerializeTask