updated AssetKey to location

dagster-io · Dec 12, 2023 · b878acb · b878acb
1 parent fb4fd15
commit b878acb
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/dbt_project/models/sources.yml b/dbt_project/models/sources.yml
@@ -8,7 +8,7 @@ sources:
       - name: "location"
         meta:
           dagster:
-            asset_key: ['raw_location']
+            asset_key: ['location']
   - name: "FORECASTING"
     tables:
       - name: "predicted_orders"
diff --git a/hooli-demo-assets/hooli_demo_assets/assets/sling.py b/hooli-demo-assets/hooli_demo_assets/assets/sling.py
@@ -3,7 +3,7 @@
 
 
 raw_location = build_sling_asset(
-    asset_spec=AssetSpec(key=["raw_location"]),
+    asset_spec=AssetSpec(key=["location"]),
     source_stream="s3://hooli-demo/embedded-elt/",
     target_object= "RAW_DATA.LOCATION",
     mode=SlingMode.FULL_REFRESH,

diff --git a/hooli-demo-assets/hooli_demo_assets/jobs/__init__.py b/hooli-demo-assets/hooli_demo_assets/jobs/__init__.py
@@ -1,6 +1,6 @@
 from dagster import AssetSelection, define_asset_job
 
-raw_location_by_day = AssetSelection.keys(["RAW_DATA", "raw_location"])
+raw_location_by_day = AssetSelection.keys(["RAW_DATA", "location"])
 
 daily_sling_job = define_asset_job(
     name="daily_sling_job",