SendBatch should pass ctx to StartPipeline

#1748
jackc · Sep 29, 2023 · a61517a · a61517a
1 parent d93f31b
commit a61517a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/conn.go b/conn.go
@@ -1090,7 +1090,7 @@ func (c *Conn) sendBatchQueryExecModeDescribeExec(ctx context.Context, b *Batch)
 }
 
 func (c *Conn) sendBatchExtendedWithDescription(ctx context.Context, b *Batch, distinctNewQueries []*pgconn.StatementDescription, sdCache stmtcache.Cache) (pbr *pipelineBatchResults) {
-	pipeline := c.pgConn.StartPipeline(context.Background())
+	pipeline := c.pgConn.StartPipeline(ctx)
 	defer func() {
 		if pbr != nil && pbr.err != nil {
 			pipeline.Close()