Core Plugins and tasks Reverse

Core Plugins and tasks Reverse
Certified
Reverse a file (last line first) in Kestra internal storage.

Copies the source file locally, writes lines in reverse order with a configurable separator, and uploads the result. Charset defaults to UTF-8.

Handy for log-like files where newest-first order is desired.

yaml
type: io.kestra.plugin.core.storage.Reverse

Examples

yaml
    id: reverse_file
    namespace: company.team

    tasks:
      - id: generate_file
        type: io.kestra.plugin.scripts.shell.Commands
        commands:
          - echo "1
2
3" > numbers.txt
        outputFiles:
          - "numbers.txt"

      - id: reverse
        type: io.kestra.plugin.core.storage.Reverse
        from: "{{ outputs.generate_file.outputFiles['numbers.txt'] }}"

Properties

from *string

The file to be split

Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.

assets

Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.

Definitions

io.kestra.core.models.assets.AssetsDeclaration

assetFailureBehaviorstring

Possible Values

IGNOREFAILWARN

Asset failure behavior

Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.

enableAutobooleanstring

Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.

inputsarray

The assets consumed as inputs.

io.kestra.core.models.assets.AssetIdentifier

id*string

Min length1

typestring

outputs

The assets produced as outputs.

io.kestra.plugin.ee.assets.Dataset

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.File

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.Table

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.VM

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.core.models.assets.External

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.core.models.assets.Custom

id*string

Min length1

Max length150

type*string

Min length1

Custom asset type

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

charset string

DefaultUTF-8

The name of a supported charset

separator string

Default\n

The separator used to join the file into chunks. By default, it's a newline \n character. If you are on Windows, you might want to use \r\n instead.

Outputs

uri string

Formaturi

The URIs of reverse files in the Kestra's internal storage