example-show-changed-assets

dbt_project/models/ANALYTICS/location_stats.sql

@@ -0,0 +1,7 @@
+select
+        order_date,
+        state,
+        count(*) as n_orders,
+        sum(order_total) as total_revenue
+from {{ ref("orders_augmented") }}
+group by 1, 2

dbt_project/models/CLEANED/orders_cleaned.sql

@@ -5,6 +5,7 @@ select
         sku,
         dt,
         cast(dt as datetime) as order_date,
+        date_trunc('month', order_date) as order_month
         quantity * purchase_price as order_total
 from {{ source("RAW_DATA", "orders") }}
 {% if is_incremental() %}

hooli-demo-assets/Dockerfile

@@ -4,4 +4,5 @@ WORKDIR /opt/dagster/app
 
 ADD . .
 
-RUN pip install -e .
+RUN python -m pip install -U uv
+RUN uv pip install --system -e .

hooli_basics/Dockerfile

@@ -4,4 +4,5 @@ WORKDIR /opt/dagster/app
 
 ADD . .
 
-RUN pip install -r requirements.txt
+RUN python -m pip install -U uv
+RUN uv pip install --system -r requirements.txt

hooli_batch_enrichment/Dockerfile

@@ -4,4 +4,5 @@ WORKDIR /opt/dagster/app
 
 ADD . .
 
-RUN pip install -e .
+RUN python -m pip install -U uv
+RUN uv pip install --system -e .

hooli_data_eng/assets/dbt_assets.py

@@ -147,7 +147,7 @@ def _process_partitioned_dbt_assets(context: OpExecutionContext, dbt: DbtCliReso
 
 @dbt_assets(
     manifest=DBT_MANIFEST,
-    select="orders_cleaned users_cleaned orders_augmented",
+    select="orders_cleaned users_cleaned orders_augmented location_stats",
     partitions_def=daily_partitions,
     dagster_dbt_translator=CustomDagsterDbtTranslator(settings=DagsterDbtTranslatorSettings(enable_asset_checks=True)),
     backfill_policy=BackfillPolicy.single_run(),

hooli_data_eng/assets/raw_data/__init__.py

@@ -82,7 +82,8 @@ def check_users(context, users: pd.DataFrame):
         backoff=Backoff.LINEAR,
         jitter=Jitter.FULL
     ),
-    backfill_policy=BackfillPolicy.single_run()
+    backfill_policy=BackfillPolicy.single_run(),
+    code_version="1"
 )
 def orders(context, api: RawDataAPI) -> pd.DataFrame:
     """A table containing all orders that have been placed"""

hooli_data_eng/resources/api.py

@@ -33,7 +33,7 @@ def get_orders(self, datetime_to_process):
 
             # random order data returned, see utils.py
             json = random_data(
-               extra_columns={"order_id": str, "quantity": int, "purchase_price": float, "sku": str},
+               extra_columns={"order_id": str, "order_desc": str, "quantity": int, "purchase_price": float, "sku": str},
                n = 10,
                filter_date=datetime_to_process
             ).to_json()

hooli_snowflake_insights/Dockerfile

@@ -9,4 +9,5 @@ RUN python -m pip install git+https://github.com/wbond/oscrypto.git@d5f3437ed242
 
 ADD . .
 
-RUN pip install -r requirements.txt
+RUN python -m pip install -U uv
+RUN uv pip install --system -r requirements.txt