We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 407e1d6 commit f1997a5Copy full SHA for f1997a5
1 file changed
hts_dagster_sample/assets/duckdb_workflow.py
@@ -13,10 +13,10 @@ def create_analytics_data():
13
return df
14
15
16
-@asset
17
-def run_duckdb_analysis(create_analytics_data, duckdb_db):
+@asset(required_resource_keys={"duckdb_db"}) # Declare the required resource
+def run_duckdb_analysis(context, create_analytics_data): # Use context to access resource
18
"""Perform DuckDB analysis"""
19
- db = duckdb_db
+ db = context.resources.duckdb_db # Access the resource through context
20
21
# Register DataFrame as table
22
db.register('analytics_data', create_analytics_data)
0 commit comments