About this integration

Dagster allows you to run dbt Cloud™ jobs alongside other technologies. You can schedule them to run as a step in a larger pipeline and manage them as a data asset.

Installation

pip install dagster-dbt

Example

from dagster_dbt import dbt_cloud_resource, load_assets_from_dbt_cloud_job
import os

# configure a resource to connect to your dbt Cloud instance
dbt_cloud = dbt_cloud_resource.configured(
    {"auth_token": os.environ["DBT_CLOUD_AUTH_TOKEN"], "account_id": 11111}
)

# import assets from dbt
dbt_cloud_assets = load_assets_from_dbt_cloud_job(
    dbt_cloud=dbt_cloud,
    job_id=33333,
)

About dbt Cloud

dbt Cloud is a hosted service for running dbt jobs. It helps data analysts and engineers productionize dbt deployments. Beyond dbt open-source, dbt Cloud provides scheduling , CI/CD, serving documentation, and monitoring & alerting.

If you're currently using dbt Cloud™, you can also use Dagster to run dbt-core in its place. You can read more about how to do that here.