Adding numerical metadata to taxi_trips_file

dagster-io · Jul 17, 2023 · 5cc3e50 · 5cc3e50
1 parent 47245f0
commit 5cc3e50
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dagster_university/assets/trips.py b/dagster_university/assets/trips.py
@@ -1,4 +1,4 @@
-from dagster import asset
+from dagster import asset, MetadataValue
 from dagster_duckdb import DuckDBResource
 
 import requests
@@ -64,6 +64,8 @@ def taxi_trips_file(context):
 
     with open(constants.TAXI_TRIPS_TEMPLATE_FILE_PATH.format(month_to_fetch), "wb") as output_file:
         output_file.write(raw_trips.content)
+    context.add_output_metadata({'Number of records': MetadataValue.int(len(raw_trips.content))})
+
 
 ## Lesson 4, 8, 6
 @asset(