FileFluxSensor(*, conn_id: str, flux_check_interval: int, filename: str, **kwargs) -> None
The file flux sensor monitors a file for a short time to check if it is still being modified.
Connection to use
Number of seconds to wait between checks that a file is stable
jinja templated string providing the path to the file to check
Passed to airflow.operators.sensors.SqlSensor
Returns the Operator's DAG if set, otherwise raises an error
Returns dag id if it has one or an adhoc + owner
Adds one additional dependency for all sensor operators that checks if a sensor task instance can be rescheduled.
@property: list of tasks directly downstream
@property: list of ids of tasks directly downstream
Total priority weight for the task. It might include all upstream or downstream tasks. depending on the weight rule. - WeightRule.ABSOLUTE - only own weight - WeightRule.DOWNSTREAM - adds priority weight of all downstream tasks - WeightRule.UPSTREAM - adds priority weight of all upstream tasks
The schedule interval of the DAG always wins over individual tasks so that tasks within a DAG always line up. The task still needs a schedule_interval as it may not be attached to a DAG.
@property: type of the task
@property: list of tasks directly upstream
@property: list of ids of tasks directly upstream