@@ -24,43 +24,43 @@ def defs() -> dg.Definitions:
2424 sensors = [discord_success_sensor , discord_failure_sensor ],
2525)
2626
27- # Pricing pipeline
28- pricing_pipeline_job = dg .define_asset_job (
27+ # Pricing pipeline job
28+ pricing_pipeline = dg .define_asset_job (
2929 name = "pricing_pipeline_job" ,
3030 selection = dg .AssetSelection .assets (build_dataframe ).downstream (include_self = True ),
3131)
3232
3333price_schedule : dg .ScheduleDefinition = dg .ScheduleDefinition (
3434 name = "price_schedule" ,
3535 cron_schedule = "0 14 * * *" ,
36- target = pricing_pipeline_job ,
36+ target = pricing_pipeline ,
3737 execution_timezone = "America/Los_Angeles" ,
3838)
3939
4040defs_pricing : dg .Definitions = dg .Definitions (
4141 assets = [build_dataframe , load_pricing_data , data_quality_checks_on_pricing ],
42- jobs = [pricing_pipeline_job ],
42+ jobs = [pricing_pipeline ],
4343 schedules = [price_schedule ],
4444)
4545
46- # Series pipeline
47- series_pipeline_job = dg .define_asset_job (
46+ # Series pipeline job
47+ series_pipeline = dg .define_asset_job (
4848 name = "series_pipeline_job" ,
4949 selection = dg .AssetSelection .assets (extract_series_data ).downstream (include_self = True ),
5050)
5151
5252defs_series : dg .Definitions = dg .Definitions (
5353 assets = [extract_series_data , load_series_data , data_quality_check_on_series ],
54- jobs = [series_pipeline_job ],
54+ jobs = [series_pipeline ],
5555)
5656
57- # Sets pipeline
58- sets_pipeline_job = dg .define_asset_job (
57+ # Sets pipeline job
58+ sets_pipeline = dg .define_asset_job (
5959 name = "sets_pipeline_job" ,
6060 selection = dg .AssetSelection .assets (extract_sets_data ).downstream (include_self = True ),
6161)
6262
6363defs_sets : dg .Definitions = dg .Definitions (
6464 assets = [extract_sets_data , load_sets_data , data_quality_check_on_sets ],
65- jobs = [sets_pipeline_job ],
65+ jobs = [sets_pipeline ],
6666)
0 commit comments