diff --git a/hooli_data_eng/assets/forecasting/__init__.py b/hooli_data_eng/assets/forecasting/__init__.py index 19a39f4..7df195d 100644 --- a/hooli_data_eng/assets/forecasting/__init__.py +++ b/hooli_data_eng/assets/forecasting/__init__.py @@ -13,6 +13,7 @@ Int, Config, AssetExecutionContext, + MaterializeResult ) from dagstermill import define_dagstermill_asset from dagster._utils import file_relative_path @@ -177,11 +178,11 @@ def big_orders(context, predicted_orders: pd.DataFrame): # or use that upstream Snowflake table, it is used here for illustrative purposes @asset( deps=[predicted_orders], - compute_kind="databricks" + compute_kind="databricks", ) def databricks_asset( context: AssetExecutionContext, pipes_client: PipesDatabricksClient -): +) -> MaterializeResult: # cluster config cluster_config = { "num_workers": 1, @@ -216,4 +217,4 @@ def databricks_asset( task=task, context=context, extras=extras, - ).get_results() + ).get_materialize_result() \ No newline at end of file