Skip to content

Commit

Permalink
feat: storage now have a namespace parameter
Browse files Browse the repository at this point in the history
  • Loading branch information
loicmathieu committed Nov 21, 2024
1 parent 9d4225a commit 70fe73c
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 5 deletions.
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
version=0.20.0-SNAPSHOT
kestraVersion=[0.18,)
kestraVersion=[0.20,)
4 changes: 1 addition & 3 deletions src/test/java/io/kestra/plugin/mongodb/BulkTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
import io.kestra.core.runners.RunContextFactory;
import io.kestra.core.storages.StorageInterface;
import io.kestra.core.utils.IdUtils;
import io.micronaut.context.annotation.Value;
import io.kestra.core.junit.annotations.KestraTest;
import jakarta.inject.Inject;
import org.junit.jupiter.api.Test;
Expand All @@ -15,7 +14,6 @@
import java.io.OutputStream;
import java.net.URI;
import java.nio.charset.StandardCharsets;
import java.util.List;
import java.util.Locale;

import static org.hamcrest.MatcherAssert.assertThat;
Expand Down Expand Up @@ -51,7 +49,7 @@ void run() throws Exception {
output.write(("{ replaceOne : {\"filter\" : { \"char\" : \"Meldane\" },\"replacement\" : { \"char\" : \"Tanys\", \"class\" : \"oracle\", \"lvl\": 4 }, \"collation\": { \"locale\": \"en\", \"strength\": 2 } } }\n").getBytes(StandardCharsets.UTF_8));
}

URI uri = storageInterface.put(null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));
URI uri = storageInterface.put(null, null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));

Bulk put = Bulk.builder()
.connection(MongoDbConnection.builder()
Expand Down
2 changes: 1 addition & 1 deletion src/test/java/io/kestra/plugin/mongodb/LoadTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ void run() throws Exception {
"name", "john"
));
}
URI uri = storageInterface.put(null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));
URI uri = storageInterface.put(null, null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));

Load put = Load.builder()
.connection(MongoDbConnection.builder()
Expand Down

0 comments on commit 70fe73c

Please sign in to comment.