airflow.providers.standard.triggers.file¶

Classes¶

`FileTrigger`	A trigger that fires exactly once after it finds the requested file or folder.
`FileDeleteTrigger`	A trigger that fires exactly once after it finds the requested file and then delete the file.

class airflow.providers.standard.triggers.file.FileTrigger(filepath, recursive=False, poke_interval=5.0, **kwargs)[source]¶

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 to False.
poke_interval (float) – Time that the job should wait in between each try

serialize()[source]¶

Serialize FileTrigger arguments and classpath.

async run()[source]¶

Loop until the relevant files are found.

class airflow.providers.standard.triggers.file.FileDeleteTrigger(filepath, poke_interval=5.0, **kwargs)[source]¶

A trigger that fires exactly once after it finds the requested file and then delete the file.

The difference between FileTrigger and FileDeleteTrigger is FileDeleteTrigger can only find a specific file.

Parameters:

filepath (str) – File (relative to the base path set within the connection).
poke_interval (float) – Time that the job should wait in between each try

serialize()[source]¶

Serialize FileDeleteTrigger arguments and classpath.

async run()[source]¶

Loop until the relevant file is found.