Description
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
Related issues
No response
Are you willing to submit a PR?
Code of Conduct
Description
Add a
bundle_nameattribute 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:
Related issues
No response
Are you willing to submit a PR?
Code of Conduct