From aa4d22346273fa9d57b2dfbba925543fe17c87e7 Mon Sep 17 00:00:00 2001
From: Mathieu Gabelle <mgabelle@kestra.io>
Date: Mon, 3 Feb 2025 13:38:20 +0100
Subject: [PATCH] refactor: rename emr plugins tasks

---
 ...{CreateCluster.java => CreateClusterAndSubmitSteps.java} | 4 ++--
 .../aws/emr/{AddJobFlowsSteps.java => SubmitSteps.java}     | 4 ++--
 .../java/io/kestra/plugin/aws/emr/EmrIntegrationTest.java   | 6 +++---
 3 files changed, 7 insertions(+), 7 deletions(-)
 rename src/main/java/io/kestra/plugin/aws/emr/{CreateCluster.java => CreateClusterAndSubmitSteps.java} (98%)
 rename src/main/java/io/kestra/plugin/aws/emr/{AddJobFlowsSteps.java => SubmitSteps.java} (95%)

diff --git a/src/main/java/io/kestra/plugin/aws/emr/CreateCluster.java b/src/main/java/io/kestra/plugin/aws/emr/CreateClusterAndSubmitSteps.java
similarity index 98%
rename from src/main/java/io/kestra/plugin/aws/emr/CreateCluster.java
rename to src/main/java/io/kestra/plugin/aws/emr/CreateClusterAndSubmitSteps.java
index 1db90da..ba28af7 100644
--- a/src/main/java/io/kestra/plugin/aws/emr/CreateCluster.java
+++ b/src/main/java/io/kestra/plugin/aws/emr/CreateClusterAndSubmitSteps.java
@@ -40,7 +40,7 @@
 
                 tasks:
                   - id: create_cluster
-                    type: io.kestra.plugin.aws.emr.CreateCluster
+                    type: io.kestra.plugin.aws.emr.CreateClusterAndSubmitSteps
                     accessKeyId: <access-key>
                     secretKeyId: <secret-key>
                     region: eu-west-3
@@ -64,7 +64,7 @@
         )
     }
 )
-public class CreateCluster extends AbstractEmrTask implements RunnableTask<CreateCluster.Output> {
+public class CreateClusterAndSubmitSteps extends AbstractEmrTask implements RunnableTask<CreateClusterAndSubmitSteps.Output> {
 
     @Schema(title = "Cluster Name.")
     @NotNull
diff --git a/src/main/java/io/kestra/plugin/aws/emr/AddJobFlowsSteps.java b/src/main/java/io/kestra/plugin/aws/emr/SubmitSteps.java
similarity index 95%
rename from src/main/java/io/kestra/plugin/aws/emr/AddJobFlowsSteps.java
rename to src/main/java/io/kestra/plugin/aws/emr/SubmitSteps.java
index fb53717..76198b3 100644
--- a/src/main/java/io/kestra/plugin/aws/emr/AddJobFlowsSteps.java
+++ b/src/main/java/io/kestra/plugin/aws/emr/SubmitSteps.java
@@ -40,7 +40,7 @@
 
                 tasks:
                   - id: add_steps_emr
-                    type: io.kestra.plugin.aws.emr.AddJobFlowsSteps
+                    type: io.kestra.plugin.aws.emr.SubmitSteps
                     accessKeyId: "<access-key>"
                     secretKeyId: "<secret-key>"
                     region: "eu-west-3"
@@ -55,7 +55,7 @@
         )
     }
 )
-public class AddJobFlowsSteps extends AbstractEmrTask implements RunnableTask<VoidOutput> {
+public class SubmitSteps extends AbstractEmrTask implements RunnableTask<VoidOutput> {
     @Schema(title = "Cluster ID.")
     @NotNull
     private Property<String> clusterId;
diff --git a/src/test/java/io/kestra/plugin/aws/emr/EmrIntegrationTest.java b/src/test/java/io/kestra/plugin/aws/emr/EmrIntegrationTest.java
index 217ec41..66eb11b 100644
--- a/src/test/java/io/kestra/plugin/aws/emr/EmrIntegrationTest.java
+++ b/src/test/java/io/kestra/plugin/aws/emr/EmrIntegrationTest.java
@@ -32,7 +32,7 @@ class EmrIntegrationTest {
 
     @Test
     void createCluster() throws Exception {
-        CreateCluster createCluster = CreateCluster.builder()
+        CreateClusterAndSubmitSteps createCluster = CreateClusterAndSubmitSteps.builder()
             .accessKeyId(Property.of(accessKeyId))
             .secretKeyId(Property.of(secretKeyId))
             .sessionToken(Property.of(sessionToken))
@@ -50,7 +50,7 @@ void createCluster() throws Exception {
             .keepJobFlowAliveWhenNoSteps(Property.of(true))
             .build();
 
-        CreateCluster.Output output = createCluster.run(runContextFactory.of());
+        CreateClusterAndSubmitSteps.Output output = createCluster.run(runContextFactory.of());
         assertNotNull(output.getJobFlowId());
     }
 
@@ -69,7 +69,7 @@ void deleteCluster() throws Exception {
 
     @Test
     void addStepsToCluster() throws Exception {
-        AddJobFlowsSteps addJobFlowsSteps = AddJobFlowsSteps.builder()
+        SubmitSteps addJobFlowsSteps = SubmitSteps.builder()
             .accessKeyId(Property.of(accessKeyId))
             .secretKeyId(Property.of(secretKeyId))
             .sessionToken(Property.of(sessionToken))