updating to reflect metadata section

dagster_university/__init__.py

@@ -22,7 +22,7 @@
 all_sensors = [adhoc_request_sensor]
 
 defs = Definitions(
-    assets=[*trip_assets, *metric_assets, *requests_assets],
+    assets=trip_assets + metric_assets + requests_assets,
     resources={
         "database": database_resource,
     },

dagster_university/assets/constants.py

@@ -1,14 +1,17 @@
-from datetime import date 
+import os
 
 TAXI_ZONES_FILE_PATH = "data/raw/taxi_zones.csv"
 TAXI_TRIPS_TEMPLATE_FILE_PATH = "data/raw/taxi_trips_{}.parquet"
 
-TRIPS_BY_AIRPORT_FILE_PATH = "data/outputs/trips_by_airport.csv"
-TRIPS_BY_WEEK_FILE_PATH = "data/outputs/trips_by_week.csv"
-MANHATTAN_STATS_FILE_PATH = "data/staging/manhattan_stats.geojson"
-MANHATTAN_MAP_FILE_PATH = "data/outputs/manhattan_map.png"
+TAXI_ZONES_FILE_PATH = os.path.join("data", "raw", "taxi_zones.csv")
+TAXI_TRIPS_TEMPLATE_FILE_PATH = os.path.join("data", "raw", "taxi_trips_{}.parquet")
 
-REQUEST_DESTINATION_TEMPLATE_FILE_PATH = "data/outputs/{}.png"
+TRIPS_BY_AIRPORT_FILE_PATH = os.path.join("data", "outputs", "trips_by_airport.csv")
+TRIPS_BY_WEEK_FILE_PATH = os.path.join("data", "outputs", "trips_by_week.csv")
+MANHATTAN_STATS_FILE_PATH = os.path.join("data", "staging", "manhattan_stats.geojson")
+MANHATTAN_MAP_FILE_PATH = os.path.join("data", "outputs", "manhattan_map.png")
+
+REQUEST_DESTINATION_TEMPLATE_FILE_PATH = os.path.join("data", "outputs", "{}.png")
 
 DATE_FORMAT = "%Y-%m-%d"
 

dagster_university/assets/metrics.py

@@ -13,7 +13,8 @@
 
 @asset(
     deps=[AssetKey(["taxi_trips"])],
-    partitions_def=weekly_partition
+    partitions_def=weekly_partition,
+    compute_kind="DuckDB",
 )
 def trips_by_week(context, database: DuckDBResource):
     """
@@ -62,7 +63,8 @@ def trips_by_week(context, database: DuckDBResource):
 ## Lesson 4 (later part)
 @asset(
     deps=[AssetKey(["taxi_trips"]), AssetKey(["taxi_zones"])],
-    key_prefix="manhattan"
+    key_prefix="manhattan",
+    compute_kind="DuckDB",
 )
 def manhattan_stats(database: DuckDBResource):
     """
@@ -92,7 +94,8 @@ def manhattan_stats(database: DuckDBResource):
 
 ## Lesson 4 (later part)
 @asset(
-    deps=[AssetKey(["manhattan", "manhattan_stats"])]
+    deps=[AssetKey(["manhattan", "manhattan_stats"])],
+    compute_kind="Python",
 )
 def manhattan_map(context):
     """

dagster_university/assets/requests.py

@@ -15,7 +15,8 @@ class AdhocRequestConfig(Config):
 
 ## Lesson 9
 @asset(
-    deps=["taxi_trips", "taxi_zones"]
+    deps=["taxi_trips", "taxi_zones"],
+    compute_kind="Python",
 )
 def adhoc_request(context, config: AdhocRequestConfig, database: DuckDBResource):
     """

dagster_university/assets/trips.py

@@ -9,7 +9,8 @@
 
 ## Lesson 3 (change this to HW)
 @asset(
-    group_name="raw_files"
+    group_name="raw_files",
+    compute_kind="Python",
 )
 def taxi_zones_file(context):
     """
@@ -28,7 +29,8 @@ def taxi_zones_file(context):
 ## Lesson 4 (HW) , 6
 @asset(
     deps=["taxi_zones_file"],
-    group_name="ingested"
+    group_name="ingested",
+    compute_kind="DuckDB",
 )
 def taxi_zones(database: DuckDBResource):
     """
@@ -52,7 +54,8 @@ def taxi_zones(database: DuckDBResource):
 ## Lesson 3, 8
 @asset(
     partitions_def=monthly_partition,
-    group_name="raw_files"
+    group_name="raw_files",
+    compute_kind="DuckDB",
 )
 def taxi_trips_file(context):
     """
@@ -76,7 +79,8 @@ def taxi_trips_file(context):
 @asset(
     deps=["taxi_trips_file"],
     partitions_def=monthly_partition,
-    group_name="ingested"
+    group_name="ingested",
+    compute_kind="DuckDB",
 )
 def taxi_trips(context, database: DuckDBResource):
     """

setup.py

@@ -13,5 +13,5 @@
         "plotly",
         "shapely",
     ],
-    extras_require={"dev": ["dagit", "pytest"]},
-)
+    extras_require={"dev": ["dagster-webserver", "pytest"]},
+)