Skip to content

Commit 94ecfcb

Browse files
authored
Merge pull request #146312 from rharding6373/blathers/backport-release-25.2-146248
release-25.2: changefeedccl: add timeout to nemeses test inserts
2 parents 4c29e4b + ed1a237 commit 94ecfcb

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

pkg/ccl/changefeedccl/cdctest/nemeses.go

+7-1
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ import (
1313
"fmt"
1414
"math/rand"
1515
"strings"
16+
"time"
1617

1718
"github.com/cockroachdb/cockroach/pkg/ccl/changefeedccl/changefeedbase"
1819
"github.com/cockroachdb/cockroach/pkg/internal/sqlsmith"
@@ -418,11 +419,16 @@ func RunNemesis(
418419

419420
defer queryGen.Close()
420421
const numInserts = 100
422+
const insertTimeout = 5 * time.Second
421423
time := timeutil.Now()
422424
for i := 0; i < numInserts; i++ {
423425
query := queryGen.Generate()
424426
log.Infof(ctx, "Executing query: %s", query)
425-
_, err := db.Exec(query)
427+
err := timeutil.RunWithTimeout(ctx, "nemeses populate table",
428+
insertTimeout, func(ctx context.Context) error {
429+
_, err := db.ExecContext(ctx, query)
430+
return err
431+
})
426432
log.Infof(ctx, "Time taken to execute last query: %s", timeutil.Since(time))
427433
time = timeutil.Now()
428434
if err != nil {

0 commit comments

Comments
 (0)