From 8a52f9d049c788fc63d6ba9ad9542e536de690c7 Mon Sep 17 00:00:00 2001 From: Lakshay Kalbhor Date: Thu, 30 Nov 2023 14:11:49 +0530 Subject: [PATCH] fix: redis results store delete job --- results/redis/results.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/results/redis/results.go b/results/redis/results.go index 314d17e..e65e9f0 100644 --- a/results/redis/results.go +++ b/results/redis/results.go @@ -72,11 +72,11 @@ func New(o Options, lo *slog.Logger) *Results { func (r *Results) DeleteJob(ctx context.Context, id string) error { r.lo.Debug("deleting job") - if err := r.conn.LRem(ctx, resultPrefix+success, 1, id).Err(); err != nil { + if err := r.conn.ZRem(ctx, resultPrefix+success, 1, id).Err(); err != nil { return err } - if err := r.conn.LRem(ctx, resultPrefix+failed, 1, id).Err(); err != nil { + if err := r.conn.ZRem(ctx, resultPrefix+failed, 1, id).Err(); err != nil { return err }