updating function name

Author: digitalghost-dev

card_data/pipelines/defs/load/tcgdex/load_sets.py

@@ -34,7 +34,7 @@ def load_sets_data(extract_sets_data: pl.DataFrame) -> None:
 
 
 @dg.asset(deps=[load_sets_data], kinds={"Soda"}, name="data_quality_checks_on_sets")
-def data_quality_check_on_series() -> None:
+def data_quality_check_on_sets() -> None:
     current_file_dir = Path(__file__).parent
     print(f"Setting cwd to: {current_file_dir}")
 

card_data/pipelines/defs/transform/transform_data.py

@@ -28,14 +28,14 @@ def get_asset_key(self, dbt_resource_props):
     manifest=DBT_PROJECT_PATH / "target" / "manifest.json",
     dagster_dbt_translator=CustomDbtTranslator()
 )
-def dbt_load_pricing_data(context: dg.AssetExecutionContext, dbt: DbtCliResource):
+def dbt_build_assets(context: dg.AssetExecutionContext, dbt: DbtCliResource):
     """
     dbt assets that transform staging data into final models.
     """
     yield from dbt.cli(["build"], context=context).stream()
 
 dbt_resource = DbtCliResource(project_dir=DBT_PROJECT_PATH)
 defs = dg.Definitions(
-    assets=[dbt_load_pricing_data],
+    assets=[dbt_build_assets],
     resources={"dbt": dbt_resource}
 )