airflow.example_dags.example_asset_allow_teams

Example DAG demonstrating cross-team asset triggering with AssetAccessControl.

When Multi-Team mode is enabled ([core] multi_team = True), asset events are filtered by team membership. By default, a consuming DAG only receives events from DAGs within the same team.

Usage:

  • team_analytics_producer (belonging to team_analytics) produces events on shared_data.

  • team_ml_consumer (belonging to team_ml) consumes shared_data.

  • Because shared_data has access_control=AssetAccessControl(producer_teams=["team_analytics"], allow_global=False), events from team_analytics are accepted by team_ml_consumer, while teamless (global) DAG producers are blocked.

  • Without access_control, the cross-team event would be blocked.

Attributes

shared_data

Module Contents

airflow.example_dags.example_asset_allow_teams.shared_data[source]

Was this entry helpful?