File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
card_data/pipelines/defs/transformation Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -28,14 +28,14 @@ def get_asset_key(self, dbt_resource_props):
2828 manifest = DBT_PROJECT_PATH / "target" / "manifest.json" ,
2929 dagster_dbt_translator = CustomDbtTranslator ()
3030)
31- def poke_cli_dbt_assets (context : dg .AssetExecutionContext , dbt : DbtCliResource ):
31+ def dbt_load_pricing_data (context : dg .AssetExecutionContext , dbt : DbtCliResource ):
3232 """
3333 dbt assets that transform staging data into final models.
3434 """
3535 yield from dbt .cli (["build" ], context = context ).stream ()
3636
3737dbt_resource = DbtCliResource (project_dir = DBT_PROJECT_PATH )
3838defs = dg .Definitions (
39- assets = [poke_cli_dbt_assets ],
39+ assets = [dbt_load_pricing_data ],
4040 resources = {"dbt" : dbt_resource }
4141)
You can’t perform that action at this time.
0 commit comments