RealtimeTrigger
yaml
type: "io.kestra.plugin.nats.realtimetrigger"
Examples
yaml
id: nats
namespace: company.team
tasks:
- id: log
type: io.kestra.plugin.core.log.Log
message: "{{ trigger.data }}"
triggers:
- id: watch
type: io.kestra.plugin.nats.RealtimeTrigger
url: nats://localhost:4222
username: nats_user
password: nats_password
subject: kestra.trigger
durableId: natsTrigger
deliverPolicy: All
Properties
subject *Requiredstring
Min length
1
url *Requiredstring
Min length
1
batchSize integer
Default
10
Minimum
>= 1
conditions Non-dynamicDateTimeBetweenDayWeekDayWeekInMonthExecutionFlowExecutionLabelsExecutionNamespaceExecutionOutputsExecutionStatusExpressionFlowConditionFlowNamespaceConditionHasRetryAttemptMultipleConditionNotOrPublicHolidayTimeBetweenWeekend
creds string
deliverPolicy string
Default
All
Possible Values
All
Last
New
ByStartSequence
ByStartTime
LastPerSubject
durableId string
password string
since string
stopAfter Non-dynamicarray
SubType string
Possible Values
CREATED
RUNNING
PAUSED
RESTARTED
KILLING
SUCCESS
WARNING
FAILED
KILLED
CANCELLED
QUEUED
RETRYING
RETRIED
SKIPPED
BREAKPOINT
token string
username string
Outputs
data string
headers object
SubType array
subject string
timestamp string
Format
date-time
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_DEADLINE
DAILY_TIME_WINDOW
DURATION_WINDOW
SLIDING_WINDOW
window string
Format
duration
windowAdvance string
Format
duration
Condition for a specific flow of an execution.
flowId *Requiredstring
namespace *Requiredstring
type *Requiredobject
Condition for a flow namespace.
namespace *Requiredstring
type *Requiredobject
prefix boolean
Default
false
Condition for a specific flow. Note that this condition is deprecated, use `io.kestra.plugin.core.condition.ExecutionFlow` instead.
flowId *Requiredstring
namespace *Requiredstring
type *Requiredobject
Condition to allow events between two specific times.
type *Requiredobject
after string
Format
time
before string
Format
time
date string
Default
{{ trigger.date }}
Condition that checks labels of an execution.
labels *Requiredarrayobject
type *Requiredobject
Condition based on the outputs of an upstream execution.
expression *Requiredbooleanstring
type *Requiredobject
Condition to allow events on weekend.
type *Requiredobject
date string
Default
{{ trigger.date }}
Condition to have at least one condition validated.
Condition for an execution namespace.
namespace *Requiredstring
type *Requiredobject
comparison string
Possible Values
EQUALS
PREFIX
SUFFIX
prefix booleanstring
Default
false
Run a flow if the list of preconditions is met in a time window.
id *Requiredstring
Validation RegExp
^[a-zA-Z0-9][a-zA-Z0-9_-]*
Min length
1
type *Requiredobject
resetOnSuccess boolean
Default
true
timeWindow TimeWindow
Default
{
"type": "DURATION_WINDOW"
}
Condition to exclude other conditions.
Condition to execute tasks on a specific day of the week relative to the current month (first, last, ...)
dayInMonth *Requiredstring
Possible Values
FIRST
LAST
SECOND
THIRD
FOURTH
dayOfWeek *Requiredstring
Possible Values
MONDAY
TUESDAY
WEDNESDAY
THURSDAY
FRIDAY
SATURDAY
SUNDAY
type *Requiredobject
date string
Default
{{ trigger.date }}
Condition based on variable expression.
expression *Requiredstring
type *Requiredobject
Condition to allow events on a particular day of the week.
dayOfWeek *Requiredstring
Possible Values
MONDAY
TUESDAY
WEDNESDAY
THURSDAY
FRIDAY
SATURDAY
SUNDAY
type *Requiredobject
date string
Default
{{ trigger.date }}
Condition based on execution status.
type *Requiredobject
in array
SubType string
Possible Values
CREATED
RUNNING
PAUSED
RESTARTED
KILLING
SUCCESS
WARNING
FAILED
KILLED
CANCELLED
QUEUED
RETRYING
RETRIED
SKIPPED
BREAKPOINT
notIn array
SubType string
Possible Values
CREATED
RUNNING
PAUSED
RESTARTED
KILLING
SUCCESS
WARNING
FAILED
KILLED
CANCELLED
QUEUED
RETRYING
RETRIED
SKIPPED
BREAKPOINT
Condition to allow events between two specific datetime values.
type *Requiredobject
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 *Requiredobject
in array
SubType string
Possible Values
CREATED
RUNNING
PAUSED
RESTARTED
KILLING
SUCCESS
WARNING
FAILED
KILLED
CANCELLED
QUEUED
RETRYING
RETRIED
SKIPPED
BREAKPOINT
notIn array
SubType string
Possible Values
CREATED
RUNNING
PAUSED
RESTARTED
KILLING
SUCCESS
WARNING
FAILED
KILLED
CANCELLED
QUEUED
RETRYING
RETRIED
SKIPPED
BREAKPOINT
Condition to allow events on public holidays.
type *Requiredobject
country string
date string
Default
{{ trigger.date }}