Transformation/Python in pipelinesData Platform Engineer

How do I manage Python dependencies for pipeline steps?

Bruin isolates Python asset environments so each step gets the packages it needs without polluting the others.

Command

bruin run

Defined in

Python + YAML

Works with

Bruin CLI + your warehouse

What you get

First-class Python assetsisolated envswarehouse materialization

How it works in code

# scores.py
""" @bruin
name: ml.scores
materialization: {type: table}
@bruin """
import pandas as pd

def materialize():
    return model.predict(load_features())

Run bruin run and Bruin runs the Python asset in its own environment and lands the output in the warehouse.

SQL and Python, one pipeline

Open source. Define assets, declare dependencies, run the graph with bruin run.

Sign up to our newsletter

Practical updates on open-source data pipelines, AI analysts, governance, and what we are shipping at Bruin.