From 163eb68866a76a9cf6a15500303725aac32f6ca3 Mon Sep 17 00:00:00 2001 From: Jack Christensen Date: Sat, 30 Sep 2023 08:50:40 -0500 Subject: [PATCH] Normalize timeout error when receiving pipeline results https://github.com/jackc/pgx/issues/1748#issuecomment-1740437138 --- pgconn/pgconn.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pgconn/pgconn.go b/pgconn/pgconn.go index 8f602e40..b4baeb14 100644 --- a/pgconn/pgconn.go +++ b/pgconn/pgconn.go @@ -1996,7 +1996,8 @@ func (p *Pipeline) GetResults() (results any, err error) { for { msg, err := p.conn.receiveMessage() if err != nil { - return nil, err + p.conn.asyncClose() + return nil, normalizeTimeoutError(p.ctx, err) } switch msg := msg.(type) {