fix(274): ignore empty data to append to msgs

fix issue 274
hibiken · Dec 10, 2023 · d0041c5 · d0041c5
1 parent 7ef0511
commit d0041c5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go
@@ -1305,6 +1305,9 @@ func (r *RDB) ListLeaseExpired(cutoff time.Time, qnames ...string) ([]*base.Task
 			return nil, errors.E(op, errors.Internal, fmt.Sprintf("cast error: Lua script returned unexpected value: %v", res))
 		}
 		for _, s := range data {
+			if len(s) == 0 {
+				continue
+			}
 			msg, err := base.DecodeMessage([]byte(s))
 			if err != nil {
 				return nil, errors.E(op, errors.Internal, fmt.Sprintf("cannot decode message: %v", err))