diff --git a/gradle.properties b/gradle.properties
index d140d9f7..3ccabc36 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -1,2 +1,2 @@
 version=0.20.0-SNAPSHOT
-kestraVersion=[0.18,)
+kestraVersion=[0.20,)
diff --git a/plugin-jdbc-clickhouse/src/test/java/io/kestra/plugin/jdbc/clickhouse/ClickHouseTest.java b/plugin-jdbc-clickhouse/src/test/java/io/kestra/plugin/jdbc/clickhouse/ClickHouseTest.java
index 8e8f8b2f..5483687e 100644
--- a/plugin-jdbc-clickhouse/src/test/java/io/kestra/plugin/jdbc/clickhouse/ClickHouseTest.java
+++ b/plugin-jdbc-clickhouse/src/test/java/io/kestra/plugin/jdbc/clickhouse/ClickHouseTest.java
@@ -113,7 +113,7 @@ void updateBatch() throws Exception {
             );
         }
 
-        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));
 
         BulkInsert taskUpdate = BulkInsert.builder()
             .from(uri.toString())
@@ -161,7 +161,7 @@ public void noSqlForInsert() throws Exception {
             ));
         }
 
-        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));
 
         BulkInsert task = BulkInsert.builder()
             .url(getUrl())
@@ -189,7 +189,7 @@ public void noSqlWithNamedColumnsForInsert() throws Exception {
             ));
         }
 
-        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));
 
         BulkInsert task = BulkInsert.builder()
             .url(getUrl())
diff --git a/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbQueriesTest.java b/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbQueriesTest.java
index 8a46365c..2f48c2cd 100644
--- a/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbQueriesTest.java
+++ b/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbQueriesTest.java
@@ -8,8 +8,6 @@
 import io.kestra.core.runners.RunContextFactory;
 import io.kestra.core.storages.StorageInterface;
 import io.kestra.core.utils.IdUtils;
-import io.kestra.plugin.jdbc.AbstractJdbcQueries;
-import io.kestra.plugin.jdbc.AbstractJdbcQuery;
 import jakarta.inject.Inject;
 import org.apache.commons.io.IOUtils;
 import org.junit.jupiter.api.Test;
@@ -18,13 +16,8 @@
 
 import java.io.File;
 import java.io.FileInputStream;
-import java.math.BigDecimal;
 import java.net.URI;
 import java.net.URL;
-import java.nio.file.Path;
-import java.time.LocalDate;
-import java.time.OffsetDateTime;
-import java.time.ZonedDateTime;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -58,10 +51,10 @@ void multiSelect() throws Exception {
             .sql("""
                 CREATE TABLE employee (id INTEGER PRIMARY KEY, name VARCHAR, age INTEGER);
                 CREATE TABLE laptop (id INTEGER PRIMARY KEY, brand VARCHAR, model VARCHAR);
-                
+
                 INSERT INTO employee(id, name, age) VALUES (1, 'John', 25), (2, 'Bryan', 35);
                 INSERT INTO laptop(id, brand, model) VALUES (1, 'Apple', 'MacBook M3 16'), (2, 'LG', 'Gram');
-                
+
                 SELECT * FROM employee where age > :age;
                 SELECT * FROM laptop;
                 """)
@@ -90,10 +83,10 @@ void multiSelectFromExistingFileInUrl() throws Exception {
             .sql("""
                 CREATE TABLE employee (id INTEGER PRIMARY KEY, name VARCHAR, age INTEGER);
                 CREATE TABLE laptop (id INTEGER PRIMARY KEY, brand VARCHAR, model VARCHAR);
-                
+
                 INSERT INTO employee(id, name, age) VALUES (1, 'John', 25), (2, 'Bryan', 35);
                 INSERT INTO laptop(id, brand, model) VALUES (1, 'Apple', 'MacBook M3 16'), (2, 'LG', 'Gram');
-                
+
                 SELECT * FROM employee where age > :age;
                 SELECT * FROM laptop;
                 """)
@@ -120,6 +113,7 @@ static Stream<String> nullOrFilledDuckDbUrl() {
     @MethodSource("nullOrFilledDuckDbUrl") // six numbers
     void inputOutputFiles(String url) throws Exception {
         URI source = storageInterface.put(
+            null,
             null,
             new URI("/" + IdUtils.create()),
             new FileInputStream(new File(Objects.requireNonNull(DuckDbQueriesTest.class.getClassLoader()
@@ -156,7 +150,7 @@ void inputOutputFiles(String url) throws Exception {
         assertThat("Query name", runOutput.getOutputs().getLast().getRow().get("name"), is("Ailane"));
 
         assertThat(
-            IOUtils.toString(storageInterface.get(null, runOutput.getOutputFiles().get("out")), Charsets.UTF_8),
+            IOUtils.toString(storageInterface.get(null, null, runOutput.getOutputFiles().get("out")), Charsets.UTF_8),
             is( "id,name\n" +
                 "4814976,Viva\n" +
                 "1010871,Voomm\n" +
diff --git a/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbTest.java b/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbTest.java
index c7d748d2..79f87a40 100644
--- a/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbTest.java
+++ b/plugin-jdbc-duckdb/src/test/java/io/kestra/plugin/jdbc/duckdb/DuckDbTest.java
@@ -259,6 +259,7 @@ static Stream<String> nullOrFilledDuckDbUrl() {
     @MethodSource("nullOrFilledDuckDbUrl") // six numbers
     void inputOutputFiles(String url) throws Exception {
         URI source = storageInterface.put(
+            null,
             null,
             new URI("/" + IdUtils.create()),
             new FileInputStream(new File(Objects.requireNonNull(DuckDbTest.class.getClassLoader()
@@ -286,7 +287,7 @@ void inputOutputFiles(String url) throws Exception {
         Query.Output runOutput = task.run(runContext);
 
         assertThat(
-            IOUtils.toString(storageInterface.get(null, runOutput.getOutputFiles().get("out")), Charsets.UTF_8),
+            IOUtils.toString(storageInterface.get(null, null, runOutput.getOutputFiles().get("out")), Charsets.UTF_8),
             is( "id,name\n" +
                 "4814976,Viva\n" +
                 "1010871,Voomm\n" +
diff --git a/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/BatchTest.java b/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/BatchTest.java
index 34057dbf..0b0b7a8b 100644
--- a/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/BatchTest.java
+++ b/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/BatchTest.java
@@ -62,7 +62,7 @@ void insert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -92,7 +92,7 @@ INSERT INTO mysql_types (
                     year_type,
                     json_type,
                     blob_type
-                ) VALUES ( 
+                ) VALUES (
                     ?,
                     ?,
                     ?,
@@ -113,7 +113,7 @@ INSERT INTO mysql_types (
                     ?,
                     ?,
                     ?,
-                    ? 
+                    ?
                 );
                  """
             )
@@ -140,7 +140,7 @@ public void namedInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -171,7 +171,7 @@ public void namedColumnsInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -220,7 +220,7 @@ public void noSqlForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -248,7 +248,7 @@ public void noSqlWithNamedColumnsForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
diff --git a/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/LoadTest.java b/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/LoadTest.java
index a3b339d5..4b45c15c 100644
--- a/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/LoadTest.java
+++ b/plugin-jdbc-mysql/src/test/java/io/kestra/plugin/jdbc/mysql/LoadTest.java
@@ -35,6 +35,7 @@ void load() throws Exception {
         URL resource = LoadTest.class.getClassLoader().getResource("load.csv");
 
         URI put = storageInterface.put(
+            null,
             null,
             new URI("/file/storage/get.yml"),
             new FileInputStream(Objects.requireNonNull(resource).getFile())
diff --git a/plugin-jdbc-oracle/src/test/java/io/kestra/plugin/jdbc/oracle/BatchTest.java b/plugin-jdbc-oracle/src/test/java/io/kestra/plugin/jdbc/oracle/BatchTest.java
index 34f4370f..f7099ca5 100644
--- a/plugin-jdbc-oracle/src/test/java/io/kestra/plugin/jdbc/oracle/BatchTest.java
+++ b/plugin-jdbc-oracle/src/test/java/io/kestra/plugin/jdbc/oracle/BatchTest.java
@@ -61,7 +61,7 @@ void insert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -92,7 +92,7 @@ public void namedInsert() throws Exception {
 
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -122,7 +122,7 @@ public void namedColumnsInsert() throws Exception {
             );
         }
 
-        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));
 
         ArrayList<String> columns = new ArrayList<>();
         columns.add("t_id");
@@ -175,7 +175,7 @@ public void noSqlForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -203,7 +203,7 @@ public void noSqlWithNamedColumnsForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
diff --git a/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/BatchTest.java b/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/BatchTest.java
index 9595b6ca..68a63038 100644
--- a/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/BatchTest.java
+++ b/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/BatchTest.java
@@ -63,7 +63,7 @@ void insert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -155,7 +155,7 @@ public void namedInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(TestUtils.url())
@@ -192,7 +192,7 @@ public void namedColumnsInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(TestUtils.url())
@@ -248,7 +248,7 @@ public void noSqlForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -282,7 +282,7 @@ public void noSqlWithNamedColumnsForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
diff --git a/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/PgsqlTest.java b/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/PgsqlTest.java
index 75d3ad7d..9dec791c 100644
--- a/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/PgsqlTest.java
+++ b/plugin-jdbc-postgres/src/test/java/io/kestra/plugin/jdbc/postgresql/PgsqlTest.java
@@ -168,7 +168,7 @@ void selectAndFetchToFile() throws Exception {
         AbstractJdbcQuery.Output runOutput = task.run(runContext);
         assertThat(runOutput.getUri(), notNullValue());
 
-        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(this.storageInterface.get(null, runOutput.getUri())));
+        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(this.storageInterface.get(null, null, runOutput.getUri())));
         int lines = 0;
         while (bufferedReader.readLine() != null) {
             lines++;
diff --git a/plugin-jdbc-snowflake/src/test/java/io/kestra/plugin/jdbc/snowflake/UploadDownloadTest.java b/plugin-jdbc-snowflake/src/test/java/io/kestra/plugin/jdbc/snowflake/UploadDownloadTest.java
index 1cd1aaf4..bb2b29c3 100644
--- a/plugin-jdbc-snowflake/src/test/java/io/kestra/plugin/jdbc/snowflake/UploadDownloadTest.java
+++ b/plugin-jdbc-snowflake/src/test/java/io/kestra/plugin/jdbc/snowflake/UploadDownloadTest.java
@@ -45,6 +45,7 @@ void success() throws Exception {
         URL resource = UploadDownloadTest.class.getClassLoader().getResource("scripts/snowflake.sql");
 
         URI put = storageInterface.put(
+            null,
             null,
             new URI("/file/storage/snowflake.sql"),
             new FileInputStream(Objects.requireNonNull(resource).getFile())
@@ -83,8 +84,8 @@ void success() throws Exception {
         assertThat(downloadRun.getUri(), notNullValue());
 
         assertThat(
-            IOUtils.toString(this.storageInterface.get(null, downloadRun.getUri()), Charsets.UTF_8),
-            is(IOUtils.toString(this.storageInterface.get(null, put), Charsets.UTF_8))
+            IOUtils.toString(this.storageInterface.get(null, null, downloadRun.getUri()), Charsets.UTF_8),
+            is(IOUtils.toString(this.storageInterface.get(null, null, put), Charsets.UTF_8))
         );
     }
 }
diff --git a/plugin-jdbc-sqlite/src/test/java/io/kestra/plugin/jdbc/sqlite/SqliteTest.java b/plugin-jdbc-sqlite/src/test/java/io/kestra/plugin/jdbc/sqlite/SqliteTest.java
index bd7bc5d7..02efb533 100644
--- a/plugin-jdbc-sqlite/src/test/java/io/kestra/plugin/jdbc/sqlite/SqliteTest.java
+++ b/plugin-jdbc-sqlite/src/test/java/io/kestra/plugin/jdbc/sqlite/SqliteTest.java
@@ -72,6 +72,7 @@ void selectFromExistingDatabase() throws Exception {
         URL resource = SqliteTest.class.getClassLoader().getResource("db/Chinook_Sqlite.sqlite");
 
         URI input = storageInterface.put(
+            null,
             null,
             new URI("/file/storage/get.yml"),
             new FileInputStream(Objects.requireNonNull(resource).getFile())
diff --git a/plugin-jdbc-sqlserver/src/test/java/io/kestra/plugin/jdbc/sqlserver/BatchTest.java b/plugin-jdbc-sqlserver/src/test/java/io/kestra/plugin/jdbc/sqlserver/BatchTest.java
index 65c20ecc..0f9b1926 100644
--- a/plugin-jdbc-sqlserver/src/test/java/io/kestra/plugin/jdbc/sqlserver/BatchTest.java
+++ b/plugin-jdbc-sqlserver/src/test/java/io/kestra/plugin/jdbc/sqlserver/BatchTest.java
@@ -64,7 +64,7 @@ void insert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -94,7 +94,7 @@ public void namedInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -125,7 +125,7 @@ public void namedColumnsInsert() throws Exception {
         }
 
 
-        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));
 
         ArrayList<String> columns = new ArrayList<>();
         columns.add("t_id");
@@ -183,7 +183,7 @@ public void noSqlForInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -211,7 +211,7 @@ public void noSqlWithNamedColumnsForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
diff --git a/plugin-jdbc-vectorwise/src/test/java/io/kestra/plugin/jdbc/vectorwise/BatchTest.java b/plugin-jdbc-vectorwise/src/test/java/io/kestra/plugin/jdbc/vectorwise/BatchTest.java
index 435a6113..552d5a02 100644
--- a/plugin-jdbc-vectorwise/src/test/java/io/kestra/plugin/jdbc/vectorwise/BatchTest.java
+++ b/plugin-jdbc-vectorwise/src/test/java/io/kestra/plugin/jdbc/vectorwise/BatchTest.java
@@ -71,7 +71,7 @@ void insert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -123,7 +123,7 @@ public void namedInsert() throws Exception {
         }
 
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -174,7 +174,7 @@ public void namedColumnsInsert() throws Exception {
 
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -224,7 +224,7 @@ public void noSqlForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -254,7 +254,7 @@ public void noSqlWithNamedColumnsForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
diff --git a/plugin-jdbc-vertica/src/test/java/io/kestra/plugin/jdbc/vertica/BatchTest.java b/plugin-jdbc-vertica/src/test/java/io/kestra/plugin/jdbc/vertica/BatchTest.java
index 86000e67..99b867bc 100644
--- a/plugin-jdbc-vertica/src/test/java/io/kestra/plugin/jdbc/vertica/BatchTest.java
+++ b/plugin-jdbc-vertica/src/test/java/io/kestra/plugin/jdbc/vertica/BatchTest.java
@@ -73,7 +73,7 @@ void insert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -105,7 +105,7 @@ public void namedInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -136,7 +136,7 @@ public void namedColumnsInsert() throws Exception {
             );
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -167,7 +167,7 @@ public void noSqlForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
@@ -195,7 +195,7 @@ public void noSqlWithNamedColumnsForInsert() throws Exception {
             ));
         }
 
-        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));
 
         Batch task = Batch.builder()
             .url(getUrl())
diff --git a/plugin-jdbc/src/test/java/io/kestra/plugin/jdbc/AbstractRdbmsTest.java b/plugin-jdbc/src/test/java/io/kestra/plugin/jdbc/AbstractRdbmsTest.java
index 317428a3..4bdc0a69 100644
--- a/plugin-jdbc/src/test/java/io/kestra/plugin/jdbc/AbstractRdbmsTest.java
+++ b/plugin-jdbc/src/test/java/io/kestra/plugin/jdbc/AbstractRdbmsTest.java
@@ -18,7 +18,6 @@
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
-import java.sql.Statement;
 import java.util.Objects;
 
 public abstract class AbstractRdbmsTest {