From aca4a66436b1e25e3342b6ed009612e05056a58a Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Tue, 21 Jan 2025 12:52:53 -0500 Subject: [PATCH] Update call site --- python_modules/libraries/dagster-dlt/dagster_dlt/resource.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python_modules/libraries/dagster-dlt/dagster_dlt/resource.py b/python_modules/libraries/dagster-dlt/dagster_dlt/resource.py index 5700889fbc484..dbc9578387486 100644 --- a/python_modules/libraries/dagster-dlt/dagster_dlt/resource.py +++ b/python_modules/libraries/dagster-dlt/dagster_dlt/resource.py @@ -23,7 +23,7 @@ from dagster_dlt.constants import META_KEY_PIPELINE, META_KEY_SOURCE, META_KEY_TRANSLATOR from dagster_dlt.dlt_event_iterator import DltEventIterator, DltEventType -from dagster_dlt.translator import DagsterDltTranslator +from dagster_dlt.translator import DagsterDltTranslator, DltResourceTranslatorData @experimental @@ -258,7 +258,7 @@ def _run( """ asset_key_dlt_source_resource_mapping = { - dagster_dlt_translator.get_asset_key(dlt_source_resource): dlt_source_resource + dagster_dlt_translator.get_asset_spec(DltResourceTranslatorData(resource=dlt_source_resource, destination=dlt_pipeline.destination)).key: dlt_source_resource for dlt_source_resource in dlt_source.selected_resources.values() }