You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Add a bundle_name attribute that references the dag bundle which populated a given dag object.
Use case/motivation
Make it easier to identify which dag bundle a dag originates from, which enables creating bundle based dag policies, e.g. filtering example dags out of the policy list or setting team specific policies:
@hookimpl
def dag_policy(dag: DAG):
if dag.bundle_name == "example_dags":
return # skip validating example dags
if dag.bundle_name == "special_dags":
... # special dag policy
Activity
jroachgolf84 commentedon Jun 15, 2026
Happy to take a spin at this one!
jroachgolf84 commentedon Jun 15, 2026
PR opened for this: #68583