From bafed907e98d78a123297eab1dcb422529cfecad Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Mon, 2 Jan 2023 13:17:18 -0800 Subject: [PATCH 1/2] Fix redis script error --- internal/rdb/rdb.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go index 7b25f15..bfe4ea3 100644 --- a/internal/rdb/rdb.go +++ b/internal/rdb/rdb.go @@ -379,7 +379,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]) @@ -416,7 +416,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]) From 783071c47f02903cc9212655bcc49ac4a828825e Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Mon, 2 Jan 2023 14:55:33 -0800 Subject: [PATCH 2/2] v0.24.0 --- CHANGELOG.md | 2 ++ internal/base/base.go | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) 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 ec342f8..eea81b5 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"