feat: storage now have a namespace parameter

kestra-io · Nov 21, 2024 · 4533dfb · 4533dfb
1 parent 79f9303
commit 4533dfb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/gradle.properties b/gradle.properties
@@ -1,2 +1,2 @@
 version=0.20.0-SNAPSHOT
-kestraVersion=[0.18,)
+kestraVersion=[0.20,)
diff --git a/src/test/java/io/kestra/plugin/surrealdb/QueryTest.java b/src/test/java/io/kestra/plugin/surrealdb/QueryTest.java
@@ -321,7 +321,7 @@ void simpleQuery_ToInternalStorage() throws Exception {
 
 		assertThat(queryCreate.getSize(), is(1L));
 
-		String outputFileContent = IOUtils.toString(storageInterface.get(null, queryCreate.getUri()), Charsets.UTF_8);
+		String outputFileContent = IOUtils.toString(storageInterface.get(null, null, queryCreate.getUri()), Charsets.UTF_8);
 		Map rows = JacksonMapper.ofIon().readValue(outputFileContent, Map.class);
 
 		assertThat(rows.get("c_string"), is("A collection doc"));
@@ -336,7 +336,7 @@ void simpleQuery_ToInternalStorage() throws Exception {
 
 		assertThat(queryResult.getSize(), is(1L));
 
-		outputFileContent = IOUtils.toString(storageInterface.get(null, queryResult.getUri()), Charsets.UTF_8);
+		outputFileContent = IOUtils.toString(storageInterface.get(null, null, queryResult.getUri()), Charsets.UTF_8);
 		rows = JacksonMapper.ofIon().readValue(outputFileContent, Map.class);
 
 		assertThat(rows.get("c_string"), is("A collection doc"));