adding a prefix to an asset

dagster-io · Jul 27, 2023 · 234865c · 234865c
1 parent a6200b8
commit 234865c
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/dagster_university/assets/metrics.py b/dagster_university/assets/metrics.py
@@ -1,4 +1,4 @@
-from dagster import asset, AssetIn, MetadataValue
+from dagster import asset, AssetKey, MetadataValue
 from dagster_duckdb import DuckDBResource
 
 import plotly.express as px
@@ -12,7 +12,7 @@
 from ..partitions import weekly_partition
 
 @asset(
-    deps=["taxi_trips"],
+    deps=[AssetKey(["taxi_trips"])],
     partitions_def=weekly_partition,
 )
 def trips_by_week(context, database: DuckDBResource):
@@ -61,7 +61,8 @@ def trips_by_week(context, database: DuckDBResource):
 
 ## Lesson 4 (later part)
 @asset(
-    deps=["taxi_trips", "taxi_zones"]
+    deps=[AssetKey(["taxi_trips"]), AssetKey(["taxi_zones"])],
+    key_prefix="manhattan"
 )
 def manhattan_stats(database: DuckDBResource):
     """
@@ -91,7 +92,7 @@ def manhattan_stats(database: DuckDBResource):
 
 ## Lesson 4 (later part)
 @asset(
-    deps=["manhattan_stats"]
+    deps=[AssetKey(["manhattan", "manhattan_stats"])]
 )
 def manhattan_map(context):
     """