diff --git a/CHANGELOG.md b/CHANGELOG.md index 76f453f..9e8628f 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -7,6 +7,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ## [Unreleased] +## [0.24.0] - 2023-01-02 + ### Added - `PreEnqueueFunc`, `PostEnqueueFunc` is added in `Scheduler` and deprecated `EnqueueErrorHandler` (PR: https://github.com/hibiken/asynq/pull/476) diff --git a/internal/base/base.go b/internal/base/base.go index 64be48a..983c7b3 100644 --- a/internal/base/base.go +++ b/internal/base/base.go @@ -23,7 +23,7 @@ import ( ) // Version of asynq library and CLI. -const Version = "0.23.0" +const Version = "0.24.0" // DefaultQueueName is the queue name used if none are specified by user. const DefaultQueueName = "default" diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go index c07ccdf..a7926ab 100644 --- a/internal/rdb/rdb.go +++ b/internal/rdb/rdb.go @@ -382,7 +382,7 @@ if redis.call("ZREM", KEYS[2], ARGV[1]) == 0 then return redis.error_reply("NOT FOUND") end if redis.call("ZADD", KEYS[3], ARGV[3], ARGV[1]) ~= 1 then - redis.redis.error_reply("INTERNAL") + return redis.error_reply("INTERNAL") end redis.call("HSET", KEYS[4], "msg", ARGV[4], "state", "completed") local n = redis.call("INCR", KEYS[5]) @@ -419,7 +419,7 @@ if redis.call("ZREM", KEYS[2], ARGV[1]) == 0 then return redis.error_reply("NOT FOUND") end if redis.call("ZADD", KEYS[3], ARGV[3], ARGV[1]) ~= 1 then - redis.redis.error_reply("INTERNAL") + return redis.error_reply("INTERNAL") end redis.call("HSET", KEYS[4], "msg", ARGV[4], "state", "completed") local n = redis.call("INCR", KEYS[5])