Trigger

yaml
type: "io.kestra.plugin.cassandra.standard.trigger"

Examples

yaml
id: cassandra_trigger
namespace: io.kestra.tests

tasks:
  - id: each
    type: io.kestra.core.tasks.flows.ForEach
    values: "{{ trigger.rows }}"
    tasks:
      - id: return
        type: io.kestra.core.tasks.debugs.Return
        format: "{{ json(taskrun.value) }}"

triggers:
  - id: watch
    type: io.kestra.plugin.cassandra.standard.Trigger
    interval: "PT5M"
    session:
       endpoints:
          - hostname: localhost
       username: cassandra_user
       password: cassandra_passwd
    cql: "SELECT * FROM CQL_KEYSPACE.CQL_TABLE"
    fetchType: FETCH

Properties

cql *string

session *CassandraDbSession

conditions DateTimeBetween DayWeek DayWeekInMonth ExecutionFlow ExecutionLabels ExecutionNamespace ExecutionOutputs ExecutionStatus Expression FlowCondition FlowNamespaceCondition HasRetryAttempt MultipleCondition Not Or PublicHoliday TimeBetween Weekend

fetchType string

Default NONE

Possible Values

STOREFETCHFETCH_ONENONE

interval string

Default PT1M

Format duration

stopAfter array

SubType string

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINT

timeZoneId string

Outputs

bytes integer

row object

rows array

SubType object

size integer

uri string

Format uri

Definitions

io.kestra.core.models.triggers.TimeWindow

deadline string

Format partial-time

endTime string

Format partial-time

startTime string

Format partial-time

type string

Default DURATION_WINDOW

Possible Values

DAILY_TIME_DEADLINEDAILY_TIME_WINDOWDURATION_WINDOWSLIDING_WINDOW

window string

Format duration

windowAdvance string

Format duration

Condition for a specific flow of an execution.

flowId *string

namespace *string

type *object

Condition for a flow namespace.

namespace *string

type *object

prefix boolean

Default false

io.kestra.plugin.cassandra.standard.CassandraDbSession-SecureConnection

keystorePassword string

keystorePath string

truststorePassword string

truststorePath string

Condition for a specific flow. Note that this condition is deprecated, use `io.kestra.plugin.core.condition.ExecutionFlow` instead.

flowId *string

namespace *string

type *object

Condition to allow events between two specific times.

type *object

after string

Format time

before string

Format time

date string

Default {{ trigger.date }}

Condition that checks labels of an execution.

labels *arrayobject

type *object

Condition based on the outputs of an upstream execution.

expression *booleanstring

type *object

Condition to allow events on weekend.

type *object

date string

Default {{ trigger.date }}

io.kestra.plugin.cassandra.standard.CassandraDbSession-Endpoint

hostname *string

Min length 1

port integerstring

Default 9042

serverName string

Condition to have at least one condition validated.

conditions *DateTimeBetween DayWeek DayWeekInMonth ExecutionFlow ExecutionLabels ExecutionNamespace ExecutionOutputs ExecutionStatus Expression FlowCondition FlowNamespaceCondition HasRetryAttempt MultipleCondition Not Or PublicHoliday TimeBetween Weekend

Min items 1

type *object

Condition for an execution namespace.

namespace *string

type *object

comparison string

Possible Values

EQUALSPREFIXSUFFIX

prefix booleanstring

Default false

Run a flow if the list of preconditions is met in a time window.

conditions *object

SubType

id *string

Validation RegExp ^[a-zA-Z0-9][a-zA-Z0-9_-]*

Min length 1

type *object

resetOnSuccess boolean

Default true

timeWindow TimeWindow

Default

{
  "type": "DURATION_WINDOW"
}

Condition to exclude other conditions.

Min items 1

type *object

Condition to execute tasks on a specific day of the week relative to the current month (first, last, ...)

dayInMonth *string

Possible Values

FIRSTLASTSECONDTHIRDFOURTH

dayOfWeek *string

Possible Values

MONDAYTUESDAYWEDNESDAYTHURSDAYFRIDAYSATURDAYSUNDAY

type *object

date string

Default {{ trigger.date }}

Condition based on variable expression.

expression *string

type *object

Condition to allow events on a particular day of the week.

dayOfWeek *string

Possible Values

MONDAYTUESDAYWEDNESDAYTHURSDAYFRIDAYSATURDAYSUNDAY

type *object

date string

Default {{ trigger.date }}

Condition based on execution status.

type *object

in array

SubType string

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINT

notIn array

SubType string

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINT

Condition to allow events between two specific datetime values.

type *object

after string

Format date-time

before string

Format date-time

date string

Default {{ trigger.date }}

Condition that matches if any taskRun has retry attempts.

type *object

in array

SubType string

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINT

notIn array

SubType string

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINT

io.kestra.plugin.cassandra.standard.CassandraDbSession

applicationName string

endpoints array

SubType

localDatacenter string

password string

secureConnection CassandraDbSession-SecureConnection

username string

Condition to allow events on public holidays.

type *object

country string

date string

Default {{ trigger.date }}

subDivision string

​Trigger

Trigger