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 2dc2cd5 commit b27d177
Show file tree
Hide file tree
Showing 7 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion src/test/java/io/kestra/plugin/github/code/SearchTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ void testParameters() throws Exception {
}

private List<Map<String, Object>> getResult(Search.Output run) throws IOException {
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, run.getUri())));
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, run.getUri())));
List<Map<String, Object>> result = new ArrayList<>();
FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));
return result;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ void testParameters() throws Exception {
}

private List<Map<String, Object>> getResult(Search.Output run) throws IOException {
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, run.getUri())));
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, run.getUri())));
List<Map<String, Object>> result = new ArrayList<>();
FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));
return result;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ void testParameters() throws Exception {
}

private List<Map<String, Object>> getResult(Search.FileOutput run) throws IOException {
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, run.getUri())));
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, run.getUri())));
List<Map<String, Object>> result = new ArrayList<>();
FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));
return result;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ void testParameters() throws Exception {
}

private List<Map<String, Object>> getResult(Search.FileOutput run) throws IOException {
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, run.getUri())));
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, run.getUri())));
List<Map<String, Object>> result = new ArrayList<>();
FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));
return result;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ void testParameters() throws Exception {
}

private List<Map<String, Object>> getResult(Search.FileOutput run) throws IOException {
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, run.getUri())));
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, run.getUri())));
List<Map<String, Object>> result = new ArrayList<>();
FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));
return result;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ void testParameters() throws Exception {
}

private List<Map<String, Object>> getResult(Search.Output run) throws IOException {
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, run.getUri())));
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, run.getUri())));
List<Map<String, Object>> result = new ArrayList<>();
FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));
return result;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ void testParameters() throws Exception {
}

private List<Map<String, Object>> getResult(Search.FileOutput run) throws IOException {
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, run.getUri())));
BufferedReader inputStream = new BufferedReader(new InputStreamReader(storageInterface.get(null, null, run.getUri())));
List<Map<String, Object>> result = new ArrayList<>();
FileSerde.reader(inputStream, r -> result.add((Map<String, Object>) r));
return result;
Expand Down

0 comments on commit b27d177

Please sign in to comment.