Skip to content

Instantly share code, notes, and snippets.

from dagster_dbt import load_assets_from_dbt_manifest
def runtime_metadata_fn(context, node_info):
return {"dbt_model": node_info["name"], "materialized": node_info["materialized"]}
dbt_assets = load_assets_from_dbt_manifest(
manifest_json=manifest_json, runtime_metadata_fn=runtime_metadata_fn
)