airflow.example_dags.example_inlet_event_extra

Example DAG to demonstrate reading asset events annotated with extra information.

Also see examples in example_outlet_event_extra.py.

Module Contents

Functions

read_asset_event(*[, inlet_events])

Attributes

asset

airflow.example_dags.example_inlet_event_extra.asset[source]
airflow.example_dags.example_inlet_event_extra.read_asset_event(*, inlet_events=None)[source]

Was this entry helpful?