diff --git a/src/main/java/io/kestra/plugin/mongodb/Trigger.java b/src/main/java/io/kestra/plugin/mongodb/Trigger.java
index f061c1a..b933bf1 100644
--- a/src/main/java/io/kestra/plugin/mongodb/Trigger.java
+++ b/src/main/java/io/kestra/plugin/mongodb/Trigger.java
@@ -33,12 +33,12 @@
 
                 tasks:
                   - id: each
-                    type: io.kestra.plugin.core.flow.EachSequential
+                    type: io.kestra.plugin.core.flow.ForEach
+					values: "{{ trigger.rows }}"
                     tasks:
                       - id: return
                         type: io.kestra.plugin.core.debug.Return
                         format: "{{ json(taskrun.value) }}"
-                    value: "{{ trigger.rows }}"
                 
                 triggers:
                   - id: watch