Skip to content

Commit

Permalink
streamingst: increase timeout on TestStreamingRegionalConstraint
Browse files Browse the repository at this point in the history
Informs #111541

Release note: none
  • Loading branch information
msbutler committed Oct 18, 2023
1 parent 3c2dc4a commit 04d9ce8
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1218,11 +1218,13 @@ func TestStreamingRegionalConstraint(t *testing.T) {
c.SrcSysServer.DB(), srcCodec, "test", "x")
destCodec := keys.MakeSQLCodec(c.Args.DestTenantID)

testutils.SucceedsSoon(t,
checkLocalities(tableDesc.PrimaryIndexSpan(srcCodec), rangedesc.NewScanner(c.SrcSysServer.DB())))
testutils.SucceedsWithin(t,
checkLocalities(tableDesc.PrimaryIndexSpan(srcCodec), rangedesc.NewScanner(c.SrcSysServer.DB())),
time.Second*45*5)

testutils.SucceedsSoon(t,
checkLocalities(tableDesc.PrimaryIndexSpan(destCodec), rangedesc.NewScanner(c.DestSysServer.DB())))
testutils.SucceedsWithin(t,
checkLocalities(tableDesc.PrimaryIndexSpan(destCodec), rangedesc.NewScanner(c.DestSysServer.DB())),
time.Second*45*5)

tableName := "test"
tabledIDQuery := fmt.Sprintf(`SELECT id FROM system.namespace WHERE name ='%s'`, tableName)
Expand Down

0 comments on commit 04d9ce8

Please sign in to comment.