Trigger
yaml
type: "io.kestra.plugin.gcp.gcs.trigger"Examples
yaml
id: gcs_listen
namespace: company.team
tasks:
- id: each
type: io.kestra.plugin.core.flow.ForEach
values: "{{ trigger.blobs | jq('.[].uri') }}"
tasks:
- id: return
type: io.kestra.plugin.core.debug.Return
format: "{{ taskrun.value }}"
triggers:
- id: watch
type: io.kestra.plugin.gcp.gcs.Trigger
interval: "PT5M"
from: gs://my-bucket/kestra/listen/
action: MOVE
moveDirectory: gs://my-bucket/kestra/archive/
yaml
id: gcs_listen
namespace: company.team
tasks:
- id: each
type: io.kestra.plugin.core.flow.EachSequential
values: "{{ trigger.blobs | jq('.[].uri') }}"
tasks:
- id: return
type: io.kestra.plugin.core.debug.Return
format: "{{ taskrun.value }}"
- id: delete
type: io.kestra.plugin.gcp.gcs.Delete
uri: "{{ taskrun.value }}"
triggers:
- id: watch
type: io.kestra.plugin.gcp.gcs.Trigger
interval: "PT5M"
from: gs://my-bucket/kestra/listen/
action: NONE
Properties
action *Requiredstring
Possible Values
MOVEDELETENONEfrom *Requiredstring
conditions Non-dynamicDateTimeBetweenDayWeekDayWeekInMonthExecutionFlowExecutionLabelsExecutionNamespaceExecutionOutputsExecutionStatusExpressionFlowConditionFlowNamespaceConditionHasRetryAttemptMultipleConditionNotOrPublicHolidayTimeBetweenWeekend
impersonatedServiceAccount string
interval Non-dynamicstring
Default
PT1M Format
durationlistingType string
Default
DIRECTORY Possible Values
RECURSIVEDIRECTORYmoveDirectory string
projectId string
regExp string
scopes array
SubType string
Default
["https://www.googleapis.com/auth/cloud-platform"]serviceAccount string
stopAfter Non-dynamicarray
SubType string
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTDefinitions
io.kestra.core.models.triggers.TimeWindow
deadline string
Format
partial-timeendTime string
Format
partial-timestartTime string
Format
partial-timetype string
Default
DURATION_WINDOW Possible Values
DAILY_TIME_DEADLINEDAILY_TIME_WINDOWDURATION_WINDOWSLIDING_WINDOWwindow string
Format
durationwindowAdvance string
Format
durationCondition 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
falseCondition 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
timebefore string
Format
timedate 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
EQUALSPREFIXSUFFIXprefix booleanstring
Default
falseRun 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
1type *Requiredobject
resetOnSuccess boolean
Default
truetimeWindow TimeWindow
Default
{
"type": "DURATION_WINDOW"
}Condition to exclude other conditions.
io.kestra.plugin.gcp.gcs.models.Blob
bucket string
cacheControl string
componentCount integer
contentDisposition string
contentEncoding string
contentLanguage string
contentType string
crc32c string
createTime string
Format
date-timecustomTime string
Format
date-timedeleteTime string
Format
date-timeetag string
eventBasedHold boolean
generatedId string
isDirectory boolean
kmsKeyName string
md5 string
mediaLink string
metaGeneration integer
metadata object
SubType string
name string
retentionExpirationTime integer
selfLink string
size integer
temporaryHold boolean
timeStorageClassUpdated string
Format
date-timeupdateTime string
Format
date-timeuri string
Format
uriCondition to execute tasks on a specific day of the week relative to the current month (first, last, ...)
dayInMonth *Requiredstring
Possible Values
FIRSTLASTSECONDTHIRDFOURTHdayOfWeek *Requiredstring
Possible Values
MONDAYTUESDAYWEDNESDAYTHURSDAYFRIDAYSATURDAYSUNDAYtype *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
MONDAYTUESDAYWEDNESDAYTHURSDAYFRIDAYSATURDAYSUNDAYtype *Requiredobject
date string
Default
{{ trigger.date }}Condition based on execution status.
type *Requiredobject
in array
SubType string
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTnotIn array
SubType string
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTCondition to allow events between two specific datetime values.
type *Requiredobject
after string
Format
date-timebefore string
Format
date-timedate string
Default
{{ trigger.date }}Condition that matches if any taskRun has retry attempts.
type *Requiredobject
in array
SubType string
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTnotIn array
SubType string
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTCondition to allow events on public holidays.
type *Requiredobject
country string
date string
Default
{{ trigger.date }}