id: fetch_logs_flow
namespace: company.team

tasks:
  - id: my_task
    type: io.kestra.plugin.scripts.shell.Commands
    commands:
      - echo "Processing data"
      - echo "Task completed"

  - id: fetch_logs
    type: io.kestra.plugin.kestra.logs.Fetch
    level: INFO
    executionId: "{{ execution.id }}"

  - id: log_count
    type: io.kestra.plugin.core.log.Log
    message: "Fetched {{ outputs.fetch_logs.size }} log entries"

id: fetch
type: io.kestra.plugin.kestra.logs.fetch
level: WARN
executionId: "{{ execution.id }}"
tasksId: 
  - "previous_task_id"