Trigger

Removes and returns an element from the head of a list periodically and create one execution per batch.

If you would like to consume each message from a list in real-time and create one execution per message, you can use the io.kestra.plugin.redis.list.RealtimeTrigger instead.

yaml
type: "io.kestra.plugin.redis.list.Trigger"

yaml
id: list_listen
namespace: company.team

tasks:
  - id: echo
    type: io.kestra.plugin.core.log.Log
    message: "{{ trigger.uri }} containing {{ trigger.count }} lines"

triggers:
  - id: watch
    type: io.kestra.plugin.redis.list.Trigger
    url: redis://localhost:6379/0
    key: mytriggerkey
    maxRecords: 2

Dynamic YES

The redis key for the list.

Dynamic YES

Default STRING

Possible Values

STRINGJSON

Format of the data contained in Redis

Dynamic YES

The connection string.

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

Dynamic YES

Default 100

Dynamic NO

Default 60

Format duration

Interval between polling.

The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.

Dynamic YES

Format duration

The max duration waiting for new rows.

It's not an hard limit and is evaluated every second.

Dynamic YES

SubType string

Dynamic NO

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

List of execution states after which a trigger should be stopped (a.k.a. disabled).

Number of elements retrieved.

Format uri

URI of a Kestra internal storage file.

​Trigger

Trigger