core.triggers.filesystem
¶
Module Contents¶
Classes¶
A trigger that fires exactly once after it finds the requested file or folder. |
Attributes¶
- core.triggers.filesystem.log¶
- class core.triggers.filesystem.FileTrigger(filepath, recursive=False, poll_interval=5.0)¶
Bases:
airflow.triggers.base.BaseTrigger
A trigger that fires exactly once after it finds the requested file or folder.
- Parameters
filepath (str) – File or folder name (relative to the base path set within the connection), can be a glob.
recursive (bool) – when set to
True
, enables recursive directory matching behavior of**
in glob filepath parameter. Defaults toFalse
.
- serialize(self)¶
Serializes FileTrigger arguments and classpath.
- async run(self)¶
Simple loop until the relevant files are found.