Merge pull request #11 from jairus-m/feat/strava-resource-v3

Use AssetExecutionContext to correctly pass in StravaAPIResource
jairus-m · Dec 23, 2024 · 4f885a0 · 4f885a0
2 parents a4dc220 + 83467a8
commit 4f885a0
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/analytics_dbt/target/manifest.json b/analytics_dbt/target/manifest.json
diff --git a/dagster_proj/assets/activities.py b/dagster_proj/assets/activities.py
@@ -2,6 +2,7 @@
     asset,
     EnvVar,
     get_dagster_logger,
+    AssetExecutionContext,
 )
 import dlt
 from dlt.sources.rest_api import RESTAPIConfig, rest_api_resources
@@ -52,8 +53,12 @@ def strava_rest_api_config(strava_resource: StravaAPIResource):
     yield from rest_api_resources(config)
 
 
-@asset(key=["strava", "activities"], group_name="dltHub")
-def load_strava_activities():
+@asset(
+    key=["strava", "activities"],
+    group_name="dltHub",
+    required_resource_keys={"strava"},
+)
+def load_strava_activities(context: AssetExecutionContext):
     """
     dlt EL pipeline based off declarative Rest API Config
     to load raw Strava activities into DuckDB
@@ -70,7 +75,7 @@ def load_strava_activities():
         progress="log",
     )
 
-    source = strava_rest_api_config(strava_api_resouce)
+    source = strava_rest_api_config(context.resources.strava)
 
     load_info = pipeline.run(source)
     logger.info(load_info)
diff --git a/data/dev/strava.duckdb b/data/dev/strava.duckdb