File system Trigger
CertifiedTrigger on NFS file changes
File system Trigger
Trigger on NFS file changes
Polls an NFS directory (default every 60s) and fires when files match on (CREATE/UPDATE). Supports regex filtering, optional recursion, and limits to maxFiles (default 25).
type: io.kestra.plugin.fs.nfs.TriggerExamples
Trigger a flow when a new CSV file arrives in an NFS directory.
id: nfs_listen
namespace: company.team
tasks:
- id: log_files
type: io.kestra.plugin.core.log.Log
message: "Received {{ trigger.files | length }} files"
triggers:
- id: watch_nfs
type: io.kestra.plugin.fs.nfs.Trigger
from: /mnt/nfs_input/data
interval: PT10S
regExp: '.*\.csv$'
on: CREATE
Properties
from *Requiredstring
Directory path to watch
allowConcurrent Non-dynamicboolean
falseSpecifies whether a trigger is allowed to start a new execution even if a previous run is still in progress.
interval Non-dynamicstring
PT1MdurationInterval between checks
maxFiles integerstring
25The maximum number of files to retrieve at once
on string
CREATE_OR_UPDATECREATEUPDATECREATE_OR_UPDATETrigger condition (CREATE, UPDATE, CREATE_OR_UPDATE)
recursive Non-dynamicboolean
falseList files recursively
regExp string
Regular expression to filter files
stateKey string
Unique key for storing the trigger state
stateTtl string
Time-to-live for the trigger state
stopAfter Non-dynamicarray
CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTEDList of execution states after which a trigger should be stopped (a.k.a. disabled).
when string
trueA condition that determines whether the trigger should run.
A Pebble expression evaluated at trigger time. The trigger fires only when the expression evaluates to a truthy value (true, a non-empty string, a non-zero number). Use this to gate trigger execution on dynamic runtime values such as execution labels, flow variables, or environment conditions.
Outputs
files array
List of files that triggered the flow, each with its change type
io.kestra.plugin.fs.nfs.Trigger-TriggeredFile
CREATEUPDATEdate-timeThe creation time of the file
Whether the file is a directory
Whether the file is hidden
Whether the file is a symbolic link
date-timeThe last access time of the file
date-timeThe last modified time of the file
The java.nio.file.Path of the file
java.nio.file.Path
The name of the file
0The size of the file in bytes
uriThe absolute URI of the file
