Merge pull request #54 from dagster-io/izzy/rename_sling_asset

updated sling asset name
dagster-io · Dec 13, 2023 · 10ab4c6 · 10ab4c6
2 parents 2a85d8d + 4cfb3aa
commit 10ab4c6
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 8 deletions.
diff --git a/dbt_project/models/CLEANED/locations_cleaned.sql b/dbt_project/models/CLEANED/locations_cleaned.sql
@@ -1,7 +1,7 @@
 with source as (
 
 select *
-from {{ source("RAW_DATA", "location") }}
+from {{ source("RAW_DATA", "locations") }}
 
 ),
 

diff --git a/dbt_project/models/sources.yml b/dbt_project/models/sources.yml
@@ -5,10 +5,7 @@ sources:
     tables:
       - name: "orders"
       - name: "users"
-      - name: "location"
-        meta:
-          dagster:
-            asset_key: ['location']
+      - name: "locations"
   - 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,9 +3,9 @@
 
 
 raw_location = build_sling_asset(
-    asset_spec=AssetSpec(key=["location"]),
+    asset_spec=AssetSpec(key=["locations"]),
     source_stream="s3://hooli-demo/embedded-elt/",
-    target_object= "RAW_DATA.LOCATION",
+    target_object= "RAW_DATA.LOCATIONS",
     mode=SlingMode.FULL_REFRESH,
     source_options={"format": "csv"},
     sling_resource_key="s3_to_snowflake_resource"

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", "location"])
+raw_location_by_day = AssetSelection.keys(["RAW_DATA", "locations"])
 
 daily_sling_job = define_asset_job(
     name="daily_sling_job",