JsonToJsonl

id: parent_json_processing
namespace: company.team
description: Parent flow that distributes work to subflows

tasks:
  - id: download
    type: io.kestra.plugin.core.http.Download
    uri: "https://api.restful-api.dev/objects"
    contentType: application/json
    method: GET
    failOnEmptyResponse: true
    timeout: PT15S

  - id: json_to_jsonl
    type: io.kestra.plugin.serdes.json.JsonToJsonl
    from: "{{ outputs.download.uri }}"

  - id: for_each_item
    type: io.kestra.plugin.core.flow.ForEachItem
    items: "{{ outputs.json_to_jsonl.uri }}"
    batch:
      rows: 1
    namespace: company.team
    flowId: child_process_item
    wait: true
    transmitFailed: true
    inputs:
      item_data: "{{ taskrun.items }}"