Handling pipe errors in transactions

[bentcoder]

Hi,

The pipe never returns error within the TxPipelined function hence if i != 0 { block always gets run. All I see at the end is that, some general purpose error message. The code never gets to return res.Err() lines. How do we prevent progressing within TxPipelined function if any pipe command fails?

Last return err always returns some vague error and I cannot wrap any valuable info to it from any pipe errors as pipe res.Err() or .Result().Error() don't return error.

Thanks

return r.Client.Watch(ctx, func(txn *redis.Tx) error {
	_, err := txn.TxPipelined(ctx, func(pipe redis.Pipeliner) error {
		var i int

		for _, item := range items {
			if res := pipe.HSet(ctx, item.key, item.field, 0); res.Err() != nil {
				return res.Err()
			}

			_ = pipe.ExpireAt(ctx, key, item.expiry)

			i++
		}

		if i != 0 {
			if res := pipe.HSet(ctx, "final", "count", i); res.Err() != nil {
				return res.Err()
			}

			_ = pipe.ExpireAt(ctx, "final", defaultExp)
		}

		return nil
	})

	return err // This just returns a general level if a pipe fails
})