From 04d9ce8ea190550e2a1fb7480b848ddbb4e27b13 Mon Sep 17 00:00:00 2001 From: Michael Butler Date: Wed, 18 Oct 2023 12:44:52 +0000 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 3bfa20036c3d..a857b8432e14 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)