diff --git a/core/src/main/java/io/kestra/plugin/core/flow/ForEachItem.java b/core/src/main/java/io/kestra/plugin/core/flow/ForEachItem.java index 12feb3bb4d3..10451fc4201 100644 --- a/core/src/main/java/io/kestra/plugin/core/flow/ForEachItem.java +++ b/core/src/main/java/io/kestra/plugin/core/flow/ForEachItem.java @@ -72,15 +72,9 @@ inputs: - id: order - type: STRING + type: FILE tasks: - - id: read_file - type: io.kestra.plugin.scripts.shell.Commands - runner: PROCESS - commands: - - cat "{{ inputs.order }}" - - id: read_file_content type: io.kestra.plugin.core.log.Log message: "{{ read(inputs.order) }}" @@ -143,7 +137,7 @@ tasks: - id: download - type: io.kestra.plugin.fs.http.Download + type: io.kestra.plugin.core.http.Download uri: "https://api.restful-api.dev/objects" contentType: application/json method: GET @@ -151,12 +145,12 @@ timeout: PT15S - id: json_to_ion - type: io.kestra.plugin.serdes.json.JsonReader + type: io.kestra.plugin.serdes.json.JsonToIon from: "{{ outputs.download.uri }}" newLine: false # regular json - id: ion_to_jsonl - type: io.kestra.plugin.serdes.json.JsonWriter + type: io.kestra.plugin.serdes.json.IonToJson from: "{{ outputs.json_to_ion.uri }}" newLine: true # JSON-L