Merge pull request #40 from shrutimantri/deprecateEachSequential

feat: replace EachSequential with ForEach
kestra-io · Nov 18, 2024 · c2db44f · c2db44f
2 parents 4ffb982 + a7c31bd
commit c2db44f
Showing 1 changed file with 23 additions and 23 deletions.
diff --git a/src/main/java/io/kestra/plugin/couchbase/Trigger.java b/src/main/java/io/kestra/plugin/couchbase/Trigger.java
@@ -30,29 +30,29 @@
         @Example(
             title = "Wait for a N1QL query to return results, and then iterate through rows.",
             full = true,
-            code = {
-                "id: couchbase-trigger",
-                "namespace: company.team",
-                "",
-                "tasks:",
-                "  - id: each",
-                "    type: io.kestra.plugin.core.flow.EachSequential",
-                "    tasks:",
-                "      - id: return",
-                "        type: io.kestra.plugin.core.debug.Return",
-                "        format: \"{{ json(taskrun.value) }}\"",
-                "    value: \"{{ trigger.rows }}\"",
-                "",
-                "triggers:",
-                "  - id: watch",
-                "    type: io.kestra.plugin.couchbase.Trigger",
-                "    interval: \"PT5M\"",
-                "    connectionString: couchbase://localhost",
-                "    username: couchbase_user",
-                "    password: couchbase_passwd",
-                "    query: SELECT * FROM `COUCHBASE_BUCKET`(.`COUCHBASE_SCOPE`.`COUCHBASE_COLLECTION`)",
-                "    fetchType: FETCH"
-            }
+            code = """
+                id: couchbase_trigger
+                namespace: company.team
+                
+                tasks:
+                  - id: each
+                    type: io.kestra.plugin.core.flow.ForEach
+                    values: "{{ trigger.rows }}"
+                    tasks:
+                      - id: return
+                        type: io.kestra.plugin.core.debug.Return
+                        format: "{{ json(taskrun.value) }}"
+                
+                triggers:
+                  - id: watch
+                    type: io.kestra.plugin.couchbase.Trigger
+                    interval: "PT5M"
+                    connectionString: couchbase://localhost
+                    username: couchbase_user
+                    password: couchbase_passwd
+                    query: SELECT * FROM `COUCHBASE_BUCKET`(.`COUCHBASE_SCOPE`.`COUCHBASE_COLLECTION`)
+                    fetchType: FETCH
+                """
         )
     }
 )