From 7442fb3d2e4246412c3b0d9d2d45bb3b09d98962 Mon Sep 17 00:00:00 2001 From: Michael Butler Date: Wed, 18 Oct 2023 08:44:52 -0400 Subject: [PATCH] streamingst: increase timeout on TestStreamingRegionalConstraint Informs #111541 Release note: none --- .../streamingest/replication_stream_e2e_test.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go b/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go index 1fd51179e1e0..669ae9053a15 100644 --- a/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go +++ b/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go @@ -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)