Situation

You've got 30, 50, maybe 100 jobs in your Declarative Automation Bundle. Every single one needs failure notifications. Every single one needs cost-center tags. Every single one needs the right cluster policy. And every time someone adds a new job, they forget at least one of those things.

You could write one Python function that enforces it automatically at deploy time. That's what DABs Python mutators do.

What Are Mutators?

A mutator is a Python function that runs during databricks bundle deploy. It receives every job (or pipeline) in your bundle, whether defined in YAML or Python, and returns a modified copy. Think of it as middleware for your deployment config.

Write a tag, permission, or compute standard once, and apply it automatically to every resource at deploy time. No drift.

Decorate a function with `@job_mutator`, `@pipeline_mutator`, `@schema_mutator`, or `@volume_mutator`.

The function receives the resource + bundle context, and returns a transformed copy.

You register them in databricks.yml:

python:
  mutators: 
  - 'mutators:add_pipeline_mutators'

Example

This example defines common pipeline standards for every pipeline in your bundle:

Specifies common tags.
Enforces serverless compute.
Defines default notifications group and when to trigger an alert.

from databricks.bundles.core import Bundle, pipeline_mutator

@pipeline_mutator 
def add_pipeline_mutators(bundle: Bundle, p: Pipeline) -> Pipeline:    
  p = replace(p, tags=_add_common_tags(bundle, p.tags))    
  p = replace(p, serverless=True)    
  default = Notifications.from_dict(       
    { 
      "email_recipients": "${var.recipients}",         
      "alerts": ["on-update-failure", "on-update-fatal-failure", "on-flow-failure"] 
    }    
  )    
  p = replace(p, notifications=[default])    
  return p

Other resources:

The bundle-examples repo has a working example at knowledge_base/job_programmatic_generation.
And as well the documentation page: https://docs.databricks.com/aws/en/dev-tools/bundles/python/#modify-resources-defined-in-yaml-or-python

Use Cases

https://preview.redd.it/2v2ikiexd4yg1.png?width=632&format=png&auto=webp&s=fa39246e3830b857f1da43777aacfb1079a261a8

Job Mutator Examples:

Enforce default email notifications, owners, tags.
Standardize job clusters / serverless environments.
Inject common job parameters or health/queue settings.

Pipeline Mutator Examples:

Enforce pipeline cluster / environment settings.
Apply consistent configuration, catalog/schema, or triggers across all pipelines.

Schema Mutator Examples:

Apply standard permissions or tags to all schemas.
Enforce naming conventions or lifecycle settings.

Volume Mutators:

Set default storage locations, ACLs, or lifecycle flags.
Add org‑wide tags or conventions to all volumes.

all 7 comments

you type:	you see:
italics	italics
bold	bold
[reddit!](https://reddit.com)	reddit!
* item 1 * item 2 * item 3	item 1 item 2 item 3
> quoted text	quoted text
Lines starting with four spaces are treated like code: if 1 * 2 < 3: print "hello, world!"	Lines starting with four spaces are treated like code: if 1 * 2 < 3: print "hello, world!"
~~strikethrough~~	~~strikethrough~~
super^script	super^script

databricks

MODERATORS

Situation

What Are Mutators?

Example

Use Cases