feat(core): rename PurgeInternalStorage to PurgeCurrentExecutionFiles

kestra-io · Jul 11, 2024 · 8885e58 · 8885e58
1 parent 883a35f
commit 8885e58
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...in/core/storage/PurgeInternalStorage.java → ...e/storage/PurgeCurrentExecutionFiles.java b/...in/core/storage/PurgeInternalStorage.java → ...e/storage/PurgeCurrentExecutionFiles.java
@@ -34,9 +34,9 @@
     },
     aliases = {"io.kestra.core.tasks.storages.PurgeExecution", "io.kestra.plugin.core.storage.PurgeExecution"}
 )
-public class PurgeInternalStorage extends Task implements RunnableTask<PurgeInternalStorage.Output> {
+public class PurgeCurrentExecutionFiles extends Task implements RunnableTask<PurgeCurrentExecutionFiles.Output> {
     @Override
-    public PurgeInternalStorage.Output run(RunContext runContext) throws Exception {
+    public PurgeCurrentExecutionFiles.Output run(RunContext runContext) throws Exception {
         return Output.builder()
             .uris(runContext.storage().deleteExecutionFiles())
             .build();

diff --git a/...ore/storage/PurgeInternalStorageTest.java → ...orage/PurgeCurrentExecutionFilesTest.java b/...ore/storage/PurgeInternalStorageTest.java → ...orage/PurgeCurrentExecutionFilesTest.java
@@ -12,7 +12,7 @@
 import static org.hamcrest.Matchers.is;
 
 @KestraTest
-class PurgeInternalStorageTest {
+class PurgeCurrentExecutionFilesTest {
     @Inject
     private RunContextFactory runContextFactory;
 
@@ -31,7 +31,7 @@ void run() throws Exception {
         var file = runContext.workingDir().createFile("test.txt", "Hello World".getBytes());
         runContext.storage().putFile(file.toFile());
 
-        var purge = PurgeInternalStorage.builder()
+        var purge = PurgeCurrentExecutionFiles.builder()
             .build();
         var output = purge.run(runContext);