We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7033297 commit ec9d28cCopy full SHA for ec9d28c
1 file changed
card_data/pipelines/defs/transformation/transform_data.py
@@ -28,14 +28,14 @@ def get_asset_key(self, dbt_resource_props):
28
manifest=DBT_PROJECT_PATH / "target" / "manifest.json",
29
dagster_dbt_translator=CustomDbtTranslator()
30
)
31
-def poke_cli_dbt_assets(context: dg.AssetExecutionContext, dbt: DbtCliResource):
+def dbt_load_pricing_data(context: dg.AssetExecutionContext, dbt: DbtCliResource):
32
"""
33
dbt assets that transform staging data into final models.
34
35
yield from dbt.cli(["build"], context=context).stream()
36
37
dbt_resource = DbtCliResource(project_dir=DBT_PROJECT_PATH)
38
defs = dg.Definitions(
39
- assets=[poke_cli_dbt_assets],
+ assets=[dbt_load_pricing_data],
40
resources={"dbt": dbt_resource}
41
0 commit comments