fix(duckshop): declare the columns staging models output and downstream models read

benchmarks/duckshop/project/models/staging/catalogue/stg_product_variants.sql

@@ -11,6 +11,9 @@ MODEL (
     is_fragile (type BOOLEAN),
     pack_size (type INT),
     attributes (type OBJECT),
+    barcodes (type ARRAY),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/catalogue/stg_products.sql

@@ -15,6 +15,8 @@ MODEL (
     is_active (type BOOLEAN),
     spec_key_count (type INT),
     specs (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/catalogue/stg_suppliers.sql

@@ -9,6 +9,8 @@ MODEL (
     primary_contact_email (type VARCHAR),
     contact_count (type INT),
     payment_terms (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/growth/stg_campaigns.sql

@@ -12,6 +12,8 @@ MODEL (
     target_regions (type ARRAY),
     target_age_min (type INT),
     target_age_max (type INT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/inventory/stg_purchase_orders.sql

@@ -10,6 +10,9 @@ MODEL (
     expected_at (type TIMESTAMP_TZ),
     received_at (type TIMESTAMP_TZ),
     line_count (type INT),
+    lines (type ARRAY),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/inventory/stg_warehouses.sql

@@ -11,6 +11,8 @@ MODEL (
     supports_same_day (type BOOLEAN),
     supports_cold_chain (type BOOLEAN),
     max_parcel_kg (type NUMBER(6, 2)),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/partners/stg_partner_listings.sql

@@ -9,6 +9,8 @@ MODEL (
     commission_pct (type NUMBER(5, 2)),
     fulfilled_by_partner (type BOOLEAN),
     terms (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_carts.sql

@@ -10,6 +10,9 @@ MODEL (
     updated_at (type TIMESTAMP_TZ),
     line_count (type INT),
     coupon_code (type VARCHAR),
+    contents (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_customer_addresses.sql

@@ -10,6 +10,11 @@ MODEL (
     latitude (type NUMBER(9, 6)),
     longitude (type NUMBER(9, 6)),
     geo (type OBJECT),
+    line1 (type VARCHAR),
+    line2 (type VARCHAR),
+    city (type VARCHAR),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_customers.sql

@@ -15,6 +15,9 @@ MODEL (
     marketing_opt_in (type BOOLEAN),
     consent_types (type ARRAY),
     birth_year (type INT),
+    preferences (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_loyalty_accounts.sql

@@ -8,6 +8,9 @@ MODEL (
     enrolled_at (type TIMESTAMP_TZ),
     tier_change_count (type INT),
     previous_tier_code (type VARCHAR),
+    tier_history (type ARRAY),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_order_lines.sql

@@ -10,6 +10,9 @@ MODEL (
     gross_amount_minor (type INT),
     tax_amount_minor (type INT),
     discount_count (type INT),
+    discounts (type ARRAY),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_orders.sql

@@ -14,6 +14,10 @@ MODEL (
     utm_campaign (type VARCHAR),
     device_type (type VARCHAR),
     item_count_hint (type INT),
+    shipping_address_id (type VARCHAR),
+    attributes (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_promotions.sql

@@ -10,6 +10,9 @@ MODEL (
     eligible_regions (type ARRAY),
     tier_count (type INT),
     max_discount_pct (type NUMBER(5, 2)),
+    rules (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/storefront/stg_wishlists.sql

@@ -6,6 +6,9 @@ MODEL (
     created_at (type TIMESTAMP_TZ),
     is_public (type BOOLEAN),
     item_count (type INT),
+    items (type ARRAY),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );
 

benchmarks/duckshop/project/models/staging/support/stg_tickets.sql

@@ -17,6 +17,8 @@ MODEL (
     tag_list (type ARRAY),
     is_vip (type BOOLEAN),
     custom_fields (type OBJECT),
+    source_seq (type NUMBER(38, 0), nullable false),
+    source_loaded_at (type TIMESTAMP_NTZ, nullable false),
   ),
 );