fix asset key prefixes in MDS assets example (#7855)

dagster-io · May 12, 2022 · c0f86a3 · c0f86a3
1 parent d917df5
commit c0f86a3
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/examples/modern_data_stack_assets/modern_data_stack_assets/assets.py b/examples/modern_data_stack_assets/modern_data_stack_assets/assets.py
@@ -12,15 +12,17 @@
 from .pandas_io_manager import pandas_io_manager
 
 airbyte_assets = build_airbyte_assets(
-    connection_id=AIRBYTE_CONNECTION_ID, destination_tables=["orders", "users"]
+    connection_id=AIRBYTE_CONNECTION_ID,
+    destination_tables=["orders", "users"],
+    asset_key_prefix=["public"],
 )
 
 dbt_assets = load_assets_from_dbt_project(
     project_dir=DBT_PROJECT_DIR, io_manager_key="pandas_io_manager"
 )
 
 
-@asset(compute_kind="python")
+@asset(compute_kind="python", namespace="public")
 def order_forecast_model(daily_order_summary: pd.DataFrame) -> Any:
     """Model parameters that best fit the observed data"""
     df = daily_order_summary
@@ -31,7 +33,7 @@ def order_forecast_model(daily_order_summary: pd.DataFrame) -> Any:
     )
 
 
-@asset(compute_kind="python", io_manager_key="pandas_io_manager")
+@asset(compute_kind="python", io_manager_key="pandas_io_manager", namespace="public")
 def predicted_orders(
     daily_order_summary: pd.DataFrame, order_forecast_model: Tuple[float, float]
 ) -> pd.DataFrame: