chore: update runContext deprecated methods

kestra-io · May 13, 2024 · 0f7c321 · 0f7c321
1 parent d31b194
commit 0f7c321
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/io/kestra/plugin/mongodb/AbstractLoad.java b/src/main/java/io/kestra/plugin/mongodb/AbstractLoad.java
@@ -53,7 +53,7 @@ public Output run(RunContext runContext) throws Exception {
 
         try (
             MongoClient client = this.connection.client(runContext);
-            BufferedReader inputStream = new BufferedReader(new InputStreamReader(runContext.uriToInputStream(from)))
+            BufferedReader inputStream = new BufferedReader(new InputStreamReader(runContext.storage().getFile(from)))
         ) {
             MongoCollection<Bson> collection = this.collection(runContext, client);
 

diff --git a/src/main/java/io/kestra/plugin/mongodb/Find.java b/src/main/java/io/kestra/plugin/mongodb/Find.java
@@ -163,7 +163,7 @@ private Pair<URI, Long> store(RunContext runContext, FindIterable<BsonDocument>
         }
 
         return Pair.of(
-            runContext.putTempFile(tempFile),
+            runContext.storage().putFile(tempFile),
             count.get()
         );
     }