feat: replace EachSequential with ForEach (#555)

kestra-io · Nov 18, 2024 · 4222c43 · 4222c43
1 parent da615e3
commit 4222c43
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/main/java/io/kestra/plugin/aws/s3/Trigger.java b/src/main/java/io/kestra/plugin/aws/s3/Trigger.java
@@ -43,12 +43,12 @@
                 
                 tasks:
                   - id: each
-                    type: io.kestra.plugin.core.flow.EachSequential
+                    type: io.kestra.plugin.core.flow.ForEach
+                    values: "{{ trigger.objects | jq('.[].uri') }}"
                     tasks:
                       - id: return
                         type: io.kestra.plugin.core.debug.Return
                         format: "{{ taskrun.value }}"
-                    value: "{{ trigger.objects | jq('.[].uri') }}"
                 
                 triggers:
                   - id: watch
@@ -74,7 +74,8 @@
                 
                 tasks:
                   - id: each
-                    type: io.kestra.plugin.core.flow.EachSequential
+                    type: io.kestra.plugin.core.flow.ForEach
+                    values: "{{ trigger.objects | jq('.[].key') }}"
                     tasks:
                       - id: return
                         type: io.kestra.plugin.core.debug.Return
@@ -87,7 +88,6 @@
                         region: "eu-central-1"
                         bucket: "my-bucket"
                         key: "{{ taskrun.value }}"
-                    value: "{{ trigger.objects | jq('.[].key') }}"
                 
                 triggers:
                   - id: watch