dagster_dbt_assets_quickstart_with_cli_resource.py

1import os
2from pathlib import Path
3
4from dagster import AssetExecutionContext, Definitions
5from dagster_dbt import DbtCliResource, dbt_assets
6
7# Update this path to point to your dbt project directory
8DBT_PROJECT_DIR = Path(__file__).joinpath("..", "..", "my_dbt_project").resolve()
9
10# Load the dbt project and its models as Dagster assets
11@dbt_assets(manifest=DBT_PROJECT_DIR.joinpath("target", "manifest.json"))
12def my_dbt_assets(context: AssetExecutionContext, dbt: DbtCliResource):
13    yield from dbt.cli(["build"], context=context).get_artifacts()
14
15# Define the Dagster definitions, including the dbt resource
16defs = Definitions(
17    assets=[my_dbt_assets],
18    resources={
19        "dbt": DbtCliResource(project_dir=os.fspath(DBT_PROJECT_DIR)),
20    },
21)