From c05ed2da4c7d06bf1e649aad0da30451f1a2cfeb Mon Sep 17 00:00:00 2001 From: "Muneeb H. Jan" Date: Tue, 28 Jan 2025 12:16:09 +0100 Subject: [PATCH] [Test] Add test for init partition reassign --- .../dms/v2/instances_management_test.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/acceptance/openstack/dms/v2/instances_management_test.go b/acceptance/openstack/dms/v2/instances_management_test.go index 945d3e883..1121362b3 100644 --- a/acceptance/openstack/dms/v2/instances_management_test.go +++ b/acceptance/openstack/dms/v2/instances_management_test.go @@ -82,6 +82,24 @@ func TestDmsManagement(t *testing.T) { t.Logf("DMSv2.1 get specification is done") } +func TestDmsInitPartitionReassigning(t *testing.T) { + t.Skip("Needs prior extensive set up. Not suitable for CI") + client, err := clients.NewDmsV2Client() + th.AssertNoErr(t, err) + + instanceId := "b56c8421-7711-4fc8-83cb-ab3714772899" + initOpts := management.InitPartitionReassigningOpts{ + Reassignments: []management.PartitionReassign{ + { + Topic: "test-topic-dms", + Brokers: []int{0, 1, 2}, + }, + }, + } + _, err = management.InitPartitionReassigning(client, instanceId, &initOpts) + th.AssertNoErr(t, err) +} + func resetPass(t *testing.T, client *golangsdk.ServiceClient, instanceId string) error { t.Helper() opts := management.PasswordOpts{NewPassword: dmsUserPasswordNew}