feat: remove usage of EachSequential (#37)

kestra-io · Nov 19, 2024 · 79f9303 · 79f9303
1 parent 35fff29
commit 79f9303
Showing 1 changed file with 26 additions and 26 deletions.
diff --git a/src/main/java/io/kestra/plugin/surrealdb/Trigger.java b/src/main/java/io/kestra/plugin/surrealdb/Trigger.java
@@ -37,32 +37,32 @@
         @Example(
             title = "Wait for SurrealQL query to return results, and then iterate through rows.",
             full = true,
-            code = {
-                "id: surrealdb_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.surrealdb.Trigger",
-                "    interval: \"PT5M\"",
-                "    host: localhost",
-                "    port: 8000",
-                "    username: surreal_user",
-                "    password: surreal_passwd",
-                "    namespace: surreal_namespace",
-                "    database: surreal_db",
-                "    fetchType: FETCH",
-                "    query: SELECT * FROM SURREAL_TABLE",
-            }
+            code = """
+                id: surrealdb_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.surrealdb.Trigger
+                    interval: "PT5M"
+                    host: localhost
+                    port: 8000
+                    username: surreal_user
+                    password: surreal_passwd
+                    namespace: surreal_namespace
+                    database: surreal_db
+                    fetchType: FETCH
+                    query: SELECT * FROM SURREAL_TABLE
+                """
         )
     }
 )