fix: redis results store delete job

kalbhor · Nov 30, 2023 · 8a52f9d · 8a52f9d
1 parent ff4f99d
commit 8a52f9d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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
 	}