fix(cli): namespace update should not try to unserialize tasks

plugin can be not present on the server that emit the command
kestra-io · Mar 22, 2023 · 900d38c · 900d38c
1 parent 809e0ea
commit 900d38c
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/cli/src/main/java/io/kestra/cli/commands/AbstractServiceNamespaceUpdateCommand.java b/cli/src/main/java/io/kestra/cli/commands/AbstractServiceNamespaceUpdateCommand.java
@@ -1,6 +1,8 @@
 package io.kestra.cli.commands;
 
 import io.kestra.cli.AbstractApiCommand;
+import lombok.*;
+import lombok.extern.jackson.Jacksonized;
 import picocli.CommandLine;
 
 import java.nio.file.Path;
@@ -14,4 +16,12 @@ public abstract class AbstractServiceNamespaceUpdateCommand extends AbstractApiC
 
     @CommandLine.Option(names = {"--no-delete"}, description = "if missing should not be deleted")
     public boolean noDelete = false ;
+
+    @Builder
+    @Value
+    @Jacksonized
+    public static class UpdateResult {
+        String id;
+        String namespace;
+    }
 }
diff --git a/cli/src/main/java/io/kestra/cli/commands/flows/namespaces/FlowNamespaceUpdateCommand.java b/cli/src/main/java/io/kestra/cli/commands/flows/namespaces/FlowNamespaceUpdateCommand.java
@@ -59,9 +59,9 @@ public Integer call() throws Exception {
                 MutableHttpRequest<String> request = HttpRequest
                     .POST("/api/v1/flows/" + namespace + "?delete=" + !noDelete, body).contentType(MediaType.APPLICATION_YAML);
 
-                List<FlowWithSource> updated = client.toBlocking().retrieve(
+                List<UpdateResult> updated = client.toBlocking().retrieve(
                     this.requestOptions(request),
-                    Argument.listOf(FlowWithSource.class)
+                    Argument.listOf(UpdateResult.class)
                 );
 
                 stdOut(updated.size() + " flow(s) for namespace '" + namespace + "' successfully updated !");

diff --git a/...main/java/io/kestra/cli/commands/templates/namespaces/TemplateNamespaceUpdateCommand.java b/...main/java/io/kestra/cli/commands/templates/namespaces/TemplateNamespaceUpdateCommand.java
@@ -47,9 +47,9 @@ public Integer call() throws Exception {
                 MutableHttpRequest<List<Template>> request = HttpRequest
                     .POST("/api/v1/templates/" + namespace + "?delete=" + !noDelete, templates);
 
-                List<Template> updated = client.toBlocking().retrieve(
+                List<UpdateResult> updated = client.toBlocking().retrieve(
                     this.requestOptions(request),
-                    Argument.listOf(Template.class)
+                    Argument.listOf(UpdateResult.class)
                 );
 
                 stdOut(updated.size() + " template(s) for namespace '" + namespace + "' successfully updated !");