feat: multi-tenant

kestra-io · Oct 13, 2023 · 088bbbf · 088bbbf
1 parent 9475ab4
commit 088bbbf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/test/java/io/kestra/plugin/elasticsearch/BulkTest.java b/src/test/java/io/kestra/plugin/elasticsearch/BulkTest.java
@@ -50,7 +50,7 @@ void run() throws Exception {
             output.write(("{ \"field1\" : \"value4\" }\n").getBytes(StandardCharsets.UTF_8));
         }
 
-        URI uri = storageInterface.put(URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));
+        URI uri = storageInterface.put(null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));
 
         Bulk put = Bulk.builder()
             .connection(ElasticsearchConnection.builder().hosts(hosts).build())

diff --git a/src/test/java/io/kestra/plugin/elasticsearch/LoadTest.java b/src/test/java/io/kestra/plugin/elasticsearch/LoadTest.java
@@ -47,7 +47,7 @@ void run() throws Exception {
                 "name", "john"
             ));
         }
-        URI uri = storageInterface.put(URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));
+        URI uri = storageInterface.put(null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile));
 
         Load put = Load.builder()
             .connection(ElasticsearchConnection.builder().hosts(hosts).build())