airflow.example_dags.example_asset_with_watchers

Example DAG for demonstrating the usage of event driven scheduling using assets and triggers.

Attributes

file_path

trigger

asset

Functions

create_file()

delete_file()

Module Contents

airflow.example_dags.example_asset_with_watchers.file_path = '/tmp/test'[source]
airflow.example_dags.example_asset_with_watchers.create_file()[source]
airflow.example_dags.example_asset_with_watchers.trigger[source]
airflow.example_dags.example_asset_with_watchers.asset[source]
airflow.example_dags.example_asset_with_watchers.delete_file()[source]

Was this entry helpful?