fix: delete zoopath of task_queue when destory cluster

housepower · Apr 8, 2024 · 0e77a79 · 0e77a79
1 parent 0d6982f
commit 0e77a79
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/service/runner/ck.go b/service/runner/ck.go
@@ -76,6 +76,11 @@ func DestroyCkCluster(task *model.Task, d deploy.CKDeploy, conf *model.CKManClic
 			}
 		}
 	}
+	taskQueuePath := fmt.Sprintf("/clickhouse/task_queue/ddl/%s", conf.Cluster)
+	if err = service.DeleteAll(taskQueuePath); err != nil {
+		return errors.Wrapf(err, "[%s]", model.NodeStatusClearData.EN)
+	}
+
 	return nil
 }