feat: storage now have a namespace parameter

kestra-io · Nov 21, 2024 · 5ef091a · 5ef091a
1 parent e18ebb0
commit 5ef091a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 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/mqtt/SuiteTest.java b/src/test/java/io/kestra/plugin/mqtt/SuiteTest.java
@@ -69,7 +69,7 @@ void run(AbstractMqttConnection.Version version, String caUri) throws Exception
             .build();
         Subscribe.Output subscribeOutput = subscribe.run(runContext);
 
-        BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, subscribeOutput.getUri())));
+        BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, subscribeOutput.getUri())));
         List<Map<String, Object>> result = new ArrayList<>();
         FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));