Fetch

type: "io.kestra.plugin.core.log.Fetch"

Fetch execution logs and store them in a file.

This task is useful to automate moving logs between various systems and environments.

Examples

id: "fetch"
type: "io.kestra.plugin.core.log.Fetch"
level: INFO
executionId: "{{ trigger.executionId }}"

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

Properties

executionId

• Type: string
• Dynamic: ✔️
• Required: ❌

Filter for a specific execution.

If not set, the task will use the ID of the current execution. If set, it will try to locate the execution on the current flow unless the namespace and flowId properties are set.

flowId

• Type: string
• Dynamic: ✔️
• Required: ❌

Filter for a specific flow identifier in case executionId is set.

level

• Type: string
• Dynamic: ❌
• Required: ❌
• Default: INFO
• Possible Values:
  • ERROR
  • WARN
  • INFO
  • DEBUG
  • TRACE

The lowest log level that you want to fetch.

namespace

• Type: string
• Dynamic: ✔️
• Required: ❌

Filter for a specific namespace in case executionId is set.

tasksId

• Type: array
• SubType: string
• Dynamic: ❌
• Required: ❌

Filter for one or more task(s).

Outputs

size

• Type: integer
• Required: ❌

The number of rows fetched.

uri

• Type: string
• Required: ❌
• Format: uri

Internal storage URI of stored results.

Stored as Amazon ION file in a row per row format.

Definitions