fix ci

streamnative · Dec 18, 2024 · 9d64f9c · 9d64f9c
1 parent c3114d3
commit 9d64f9c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pulsar/resource_pulsar_topic_test.go b/pulsar/resource_pulsar_topic_test.go
@@ -65,13 +65,17 @@ func TestImportExistingTopic(t *testing.T) {
 	pnum := 10
 
 	fullID := strings.Join([]string{ttype + ":/", "public", "default", tname}, "/")
+	topicName, err := utils.GetTopicName(fullID)
+	if err != nil {
+		t.Fatalf("ERROR_GETTING_TOPIC_NAME: %v", err)
+	}
 
 	resource.Test(t, resource.TestCase{
 		PreCheck: func() {
 			testAccPreCheck(t)
 			createTopic(t, fullID, pnum)
 			t.Cleanup(func() {
-				if err := getClientFromMeta(testAccProvider.Meta()).Topics().Delete(fullID); err != nil {
+				if err := getClientFromMeta(testAccProvider.Meta()).Topics().Delete(*topicName, true, pnum == 0); err != nil {
 					t.Fatalf("ERROR_DELETING_TEST_TOPIC: %v", err)
 				}
 			})