From 4222c436db55894a8de17f4af5f5637b0c3a0570 Mon Sep 17 00:00:00 2001
From: Shruti Mantri <shruti1810@gmail.com>
Date: Mon, 18 Nov 2024 22:48:39 +0530
Subject: [PATCH] feat: replace EachSequential with ForEach (#555)

---
 src/main/java/io/kestra/plugin/aws/s3/Trigger.java | 8 ++++----
 1 file changed, 4 insertions(+), 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
index 8477688..06e13bd 100644
--- 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