diff --git a/apps/other/src/definitions.py b/apps/other/src/definitions.py index 46bc5a7..f7b647c 100644 --- a/apps/other/src/definitions.py +++ b/apps/other/src/definitions.py @@ -2,23 +2,23 @@ import assets from dagster_polars import PolarsParquetIOManager from icecream import install -from dagster import Definitions, define_asset_job, load_assets_from_modules +import dagster as dg install() # Define a job that includes both assets -daily_job = define_asset_job( +daily_job = dg.define_asset_job( "daily_job", selection=[assets.asset_multi_1, assets.asset_multi_2], ) -definitions = Definitions( +definitions = dg.Definitions( assets=[ asset.with_attributes( group_names_by_key={asset.key: "other"}, tags_by_key={asset.key: {"app": "other"}}, ) - for asset in load_assets_from_modules([assets]) + for asset in dg.load_assets_from_modules([assets]) ], resources={ "polars_parquet_io_manager": PolarsParquetIOManager(base_dir="/storage")