enable pipeline deletion

pluralsh · Jan 9, 2024 · 0ee4861 · 0ee4861
1 parent 9c7d398
commit 0ee4861
Showing 1 changed file with 9 additions and 10 deletions.
diff --git a/controller/internal/client/pipeline.go b/controller/internal/client/pipeline.go
@@ -36,16 +36,15 @@ func (c *client) ListPipelines() (*console.GetPipelines, error) {
 }
 
 func (c *client) DeletePipeline(id string) (*console.PipelineFragment, error) {
-	// TODO: response, err := c.consoleClient.DeletePipeline(c.ctx, id)
-	//if err != nil {
-	//	return nil, err
-	//}
-	//if response == nil {
-	//	return nil, err
-	//}
-	//
-	//return response.DeleteCluster, nil
-	return nil, nil
+	response, err := c.consoleClient.DeletePipeline(c.ctx, id)
+	if err != nil {
+		return nil, err
+	}
+	if response == nil {
+		return nil, err
+	}
+
+	return response.DeletePipeline, nil
 }
 
 func (c *client) IsPipelineExisting(id string) bool {