From 2e6f38a7dc68360efe6406b24bd1f45cd29fee32 Mon Sep 17 00:00:00 2001 From: Matt Lord Date: Thu, 6 Feb 2025 14:09:25 -0500 Subject: [PATCH] Adjust test Signed-off-by: Matt Lord --- go/test/endtoend/vreplication/migrate_test.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/go/test/endtoend/vreplication/migrate_test.go b/go/test/endtoend/vreplication/migrate_test.go index ef20d953781..676ce128fa0 100644 --- a/go/test/endtoend/vreplication/migrate_test.go +++ b/go/test/endtoend/vreplication/migrate_test.go @@ -96,8 +96,9 @@ func TestMigrateUnsharded(t *testing.T) { var output, expected string t.Run("mount external cluster", func(t *testing.T) { + etcdHostPort := fmt.Sprintf("localhost:%d", extVc.ClusterConfig.topoPort) output, err := vc.VtctldClient.ExecuteCommandWithOutput("Mount", "register", "--name=ext1", "--topo-type=etcd2", - fmt.Sprintf("--topo-server=localhost:%d", extVc.ClusterConfig.topoPort), "--topo-root=/vitess/global") + "--topo-server", etcdHostPort, "--topo-root=/vitess/global") require.NoError(t, err, "Mount Register command failed with %s", output) output, err = vc.VtctldClient.ExecuteCommandWithOutput("Mount", "list") @@ -110,7 +111,7 @@ func TestMigrateUnsharded(t *testing.T) { require.NoError(t, err, "Mount command failed with %s\n", output) require.Equal(t, "etcd2", gjson.Get(output, "topo_type").String()) - require.Equal(t, "localhost:12379", gjson.Get(output, "topo_server").String()) + require.Equal(t, etcdHostPort, gjson.Get(output, "topo_server").String()) require.Equal(t, "/vitess/global", gjson.Get(output, "topo_root").String()) })