fix: compilation

kestra-io · Aug 5, 2024 · e70bc71 · e70bc71
1 parent 51758ec
commit e70bc71
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 5 deletions.
diff --git a/src/main/java/io/kestra/plugin/git/Push.java b/src/main/java/io/kestra/plugin/git/Push.java
@@ -245,7 +245,7 @@ public Output run(RunContext runContext) throws Exception {
                 .findAllFilesMatching(this.namespaceFiles.getInclude(), this.namespaceFiles.getExclude())
                 .forEach(Rethrow.throwConsumer(namespaceFile -> {
                     InputStream content = runContext.storage().getFile(namespaceFile.uri());
-                    runContext.workingDir().putFile(namespaceFile.path(), content);
+                    runContext.workingDir().putFile(Path.of(namespaceFile.path()), content);
                 }));
         }
 

diff --git a/src/main/java/io/kestra/plugin/git/PushNamespaceFiles.java b/src/main/java/io/kestra/plugin/git/PushNamespaceFiles.java
@@ -140,7 +140,7 @@ protected Map<Path, Supplier<InputStream>> instanceResourcesContentByPath(RunCon
             .stream()
             .collect(Collectors.toMap(
                 nsFile -> baseDirectory.resolve(nsFile.path(false)),
-                throwFunction(nsFile -> throwSupplier(() -> storage.getFileContent(nsFile.path())))
+                throwFunction(nsFile -> throwSupplier(() -> storage.getFileContent(Path.of(nsFile.path()))))
             ));
     }
 

diff --git a/src/main/java/io/kestra/plugin/git/SyncNamespaceFiles.java b/src/main/java/io/kestra/plugin/git/SyncNamespaceFiles.java
@@ -13,6 +13,7 @@
 import java.io.IOException;
 import java.io.InputStream;
 import java.net.URI;
+import java.net.URISyntaxException;
 import java.nio.file.Path;
 import java.util.List;
 import java.util.Optional;
@@ -108,9 +109,13 @@ protected URI simulateResourceWrite(RunContext runContext, String renderedNamesp
     protected URI writeResource(RunContext runContext, String renderedNamespace, URI uri, InputStream inputStream) throws IOException {
         Namespace namespace = runContext.storage().namespace(renderedNamespace);
 
-        return inputStream == null ?
-            URI.create(namespace.createDirectory(Path.of(uri.getPath())) + "/") :
-            namespace.putFile(Path.of(uri.getPath()), inputStream).uri();
+        try {
+            return inputStream == null ?
+                URI.create(namespace.createDirectory(Path.of(uri.getPath())) + "/") :
+                namespace.putFile(Path.of(uri.getPath()), inputStream).uri();
+        } catch (URISyntaxException e) {
+            throw new IOException(e);
+        }
     }
 
     @Override