func (p *Persister) Rollback(ctx context.Context) (err error) {
    ctx, span := p.r.Tracer(ctx).Tracer().Start(ctx, "persistence.sql.Rollback")
    defer otelx.End(span, &err)

    if skip, ok := ctx.Value(skipCommitKey).(bool); ok && skip {