Airflow Summit 2025 将于 10 月 07-09 日举行。立即注册获取早鸟票!

airflow.example_dags.example_asset_with_watchers

演示如何使用资产和触发器进行事件驱动调度的示例 DAG。

属性

file_path

trigger

asset

函数

test_task()

模块内容

airflow.example_dags.example_asset_with_watchers.file_path = '/tmp/test'[源代码]
airflow.example_dags.example_asset_with_watchers.trigger[源代码]
airflow.example_dags.example_asset_with_watchers.asset[源代码]
airflow.example_dags.example_asset_with_watchers.test_task()[源代码]

本条目有帮助吗?