GOMODULES
/
pgx
mirror of https://github.com/jackc/pgx.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Because CI runs on a potato

pull/1658/head
Jack Christensen 2023-06-20 08:42:56 -05:00
parent e79efdacf9
commit 0d14b87140
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pgconn/pgconn_test.go
View File

@ -2220,7 +2220,7 @@ func TestConnEscapeString(t *testing.T) {
func TestConnCancelRequest(t *testing.T) { func TestConnCancelRequest(t *testing.T) {
t.Parallel() t.Parallel()
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel() defer cancel()
pgConn, err := pgconn.Connect(ctx, os.Getenv("PGX_TEST_DATABASE")) pgConn, err := pgconn.Connect(ctx, os.Getenv("PGX_TEST_DATABASE"))
@ -2231,13 +2231,13 @@ func TestConnCancelRequest(t *testing.T) {
t.Skip("Server does not support query cancellation (https://github.com/cockroachdb/cockroach/issues/41335)") t.Skip("Server does not support query cancellation (https://github.com/cockroachdb/cockroach/issues/41335)")
} }
multiResult := pgConn.Exec(ctx, "select 'Hello, world', pg_sleep(2)") multiResult := pgConn.Exec(ctx, "select 'Hello, world', pg_sleep(25)")
errChan := make(chan error) errChan := make(chan error)
go func() { go func() {
// The query is actually sent when multiResult.NextResult() is called. So wait to ensure it is sent. // The query is actually sent when multiResult.NextResult() is called. So wait to ensure it is sent.
// Once Flush is available this could use that instead. // Once Flush is available this could use that instead.
time.Sleep(500 * time.Millisecond) time.Sleep(1 * time.Second)
err := pgConn.CancelRequest(ctx) err := pgConn.CancelRequest(ctx)
errChan <- err errChan <- err