stg_gcs__whse_inventory

staging view

Stock positions by lot, typed and FK-validated.

Definition

Cleaned mirror of `raw_gcs.whse_inventory`. Coerces the CSV's `Nullable(String)` columns into typed equivalents and enforces FKs to `stg_gcs__whse_products` and `stg_gcs__whse_sites`. `client_id` is denormalized from the product owner and hardened by an INC-22 integrity test so the row policy on mart_inventory_health stays sound.

16 of 16

Column

Description

Tests · PII

lot_id

UUID5 from the source CSV. Primary key.

3 tests

sku

Foreign key to stg_gcs__whse_products.

2 tests

site_id

Foreign key to stg_gcs__whse_sites.

2 tests

client_id

Denormalized owning client (from the product owner), carried for the row policy. INC-22 model-level integrity test asserts equality to the product owner.

client_contact +1 PII1 test

lot_code

Human lot/batch code. Free-text.

qty_on_hand

Units on hand. Coerced from String → Int32.

1 test

qty_allocated

Units allocated (≤ qty_on_hand). Coerced from String → Int32.

zone

Bin zone (correlates with product temp/hazard class).

2 tests

bin_location

Bin location, e.g. `A-12-04`. Free-text.

received_date

Date the lot was received. Coerced from String → Date. Source of `inv_month` downstream.

1 test

lot_expiry

Lot expiry date. Nullable — null for non-perishable SKUs. Coerced from String → Nullable(Date).

inventory_status

Inventory status.

2 tests

unit_cost_eur

Snapshot unit cost in EUR. Coerced from String → Decimal(14,2).

source_file_url

Airbyte-supplied `_ab_source_file_url` — the gs:// URI the row came from.

source_file_modified_at

Airbyte-supplied `_ab_source_file_last_modified` — object mtime of the source file.

airbyte_extracted_at

When Airbyte extracted this row from GCS.