id: opensearch_bulk_load
    namespace: company.team

    inputs:
      - id: file
        type: FILE

tasks:
  - id: bulk_load
    type: io.kestra.plugin.opensearch.Bulk
    connection:
      hosts:
        - "http://localhost:9200"
    from: "{{ inputs.file }}"
    # `inputs.file` must contain alternating action and source lines as expected by the Bulk API.