introduce pricing_pipeline_job and update schedule

Author: digitalghost-dev

card_data/pipelines/definitions.py

@@ -27,13 +27,21 @@ def defs():
 def dbt_models(context: dg.AssetExecutionContext, dbt: DbtCliResource):
     yield from dbt.cli(["build"], context=context).stream()
 
+# Define the pricing pipeline job that materializes both assets
+pricing_pipeline_job = dg.define_asset_job(
+    name="pricing_pipeline_job",
+    selection=dg.AssetSelection.assets(build_dataframe, load_pricing_data),
+)
+
 price_schedule = dg.ScheduleDefinition(
     name="price_schedule",
     cron_schedule="10 10 * * *",
-    target=[build_dataframe, load_pricing_data],
+    target=pricing_pipeline_job,
     execution_timezone="America/Los_Angeles",
 )
 
 defs_pricing = dg.Definitions(
+    assets=[build_dataframe, load_pricing_data],
+    jobs=[pricing_pipeline_job],
     schedules=[price_schedule],
 )