airflow.example_dags.example_inlet_event_extra¶

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

Also see examples in example_outlet_event_extra.py.

Attributes¶

Functions¶

read_dataset_event(*[, inlet_events])

Module Contents¶

airflow.example_dags.example_inlet_event_extra.ds[source]¶

airflow.example_dags.example_inlet_event_extra.read_dataset_event(*, inlet_events=None)[source]¶

Was this entry helpful?