Skip to content

Commit

Permalink
feat: replace EachSequential with ForEach (#441)
Browse files Browse the repository at this point in the history
  • Loading branch information
@shrutimantri
shrutimantri authored Nov 18, 2024
1 parent 9f74e9f commit 0b4037c
Show file tree
Hide file tree
Showing 19 changed files with 38 additions and 38 deletions.
4 changes: 2 additions & 2 deletions plugin-jdbc-arrow-flight/src/main/java/io/kestra/plugin/jdbc/arrowflight/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -35,12 +35,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-as400/src/main/java/io/kestra/plugin/jdbc/as400/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-clickhouse/src/main/java/io/kestra/plugin/jdbc/clickhouse/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-db2/src/main/java/io/kestra/plugin/jdbc/db2/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,12 +31,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-dremio/src/main/java/io/kestra/plugin/jdbc/dremio/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-druid/src/main/java/io/kestra/plugin/jdbc/druid/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -35,12 +35,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-duckdb/src/main/java/io/kestra/plugin/jdbc/duckdb/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-mysql/src/main/java/io/kestra/plugin/jdbc/mysql/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,12 +32,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-oracle/src/main/java/io/kestra/plugin/jdbc/oracle/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-pinot/src/main/java/io/kestra/plugin/jdbc/pinot/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -35,12 +35,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-postgres/src/main/java/io/kestra/plugin/jdbc/postgresql/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,12 +31,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-redshift/src/main/java/io/kestra/plugin/jdbc/redshift/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-snowflake/src/main/java/io/kestra/plugin/jdbc/snowflake/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-sqlite/src/main/java/io/kestra/plugin/jdbc/sqlite/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,12 +31,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-sqlserver/src/main/java/io/kestra/plugin/jdbc/sqlserver/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-sybase/src/main/java/io/kestra/plugin/jdbc/sybase/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,12 +32,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-trino/src/main/java/io/kestra/plugin/jdbc/trino/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-vectorwise/src/main/java/io/kestra/plugin/jdbc/vectorwise/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down
4 changes: 2 additions & 2 deletions plugin-jdbc-vertica/src/main/java/io/kestra/plugin/jdbc/vertica/Trigger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,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
Expand Down

0 comments on commit 0b4037c

Please sign in to comment.