Use when scoping a new data product or formalizing checks on an existing one. Reads a data PRD, dataset README or lineage doc and writes a data contract: schema with types, nullability and PII flags, freshness SLA, volume bounds, distribution rules and owner, for dbt, Great Expectations or Soda.
95%
Does it follow best practices?
Run evals on this skill
Adds up to 20 points to the overall score
Passed
No findings from the security scan
This skill formalizes the prose of a data PRD into a data contract -
the producer/consumer agreement on schema, freshness, volume, semantic
invariants, and ownership - that the QA test suite can mechanically
assert against, typically via the sibling skills in this plugin
(dbt-testing, great-expectations, soda-checks). "Data contract" is
practitioner-emergent terminology (Andrew Jones / Chad Sanderson), not
ISTQB-canonical; this skill cites industry-engineering sources.
The five required sections, in order of authoring priority:
For each column:
| Field | Required | Notes |
|---|---|---|
| Name | yes | snake_case; matches the warehouse table. |
| Type | yes | Warehouse-native type (VARCHAR, BIGINT, TIMESTAMP, etc.). |
| Nullable | yes | true / false - the test suite's not_null decision. |
| PK | yes | true for primary-key column(s). |
| Unique | yes | true for candidate keys (separate from PK). |
| FK | optional | If foreign key, the <table>.<column> reference. |
| PII | required | Tag values: none, direct (email/name), indirect (zip, dob alone), sensitive (SSN, payment). |
| Constraint | optional | Range / enum / regex (per the sibling data-quality-conventions skill). |
| Description | yes | One-sentence semantic meaning; not just the type. |
| Field | Notes |
|---|---|
| Update cadence | daily / hourly / continuous / weekly. |
| Max staleness | The point past which downstream consumers should treat the data as broken (per the sibling data-quality-conventions skill: typically 2× cadence). |
| Source-of-truth column | The timestamp column the freshness check reads (e.g. updated_at, loaded_at, event_time). |
| Field | Notes |
|---|---|
| Expected min/max | Row-count range under normal operation. |
| Volatility | stable / monotonic-growth / cyclical / event-driven. |
| Recovery action | If volume falls outside bounds, what does the consumer do? |
For each business-meaningful column, what must hold:
| Field | Example |
|---|---|
| Categorical: accepted values | status ∈ {placed, shipped, completed, returned}. |
| Numeric: range | discount_pct ∈ [0, 100]. |
| Frequency / rate | cancellation_rate ≤ 5% (rolling 7-day window). |
| Field | Notes |
|---|---|
| Producer team | Who runs the pipeline. |
| Owner handle | Routing handle (Slack / email) for breaks. |
| Consumers | Known downstream models / dashboards / services. |
| Versioning | How breaking changes are communicated. |
Emit as YAML for direct consumption by dbt / GX / Soda:
# data-contracts/<dataset-slug>.yml
contract_version: 1
dataset:
name: orders
description: One row per customer order; updated within 1h of placement.
schema:
- name: order_id
type: BIGINT
nullable: false
pk: true
unique: true
pii: none
description: Surrogate key.
- name: customer_id
type: BIGINT
nullable: false
fk: customers.customer_id
pii: indirect
description: Customer who placed the order.
- name: email
type: VARCHAR
nullable: false
pii: direct
constraint: { format: email }
description: Customer email at time of order (immutable snapshot).
- name: status
type: VARCHAR
nullable: false
constraint:
accepted_values: [placed, shipped, completed, returned]
description: Current fulfillment status.
- name: discount_pct
type: DECIMAL(5,2)
nullable: true
constraint: { range: [0, 100] }
description: Promotion discount applied; null = no promo.
- name: updated_at
type: TIMESTAMP
nullable: false
description: Last-modified timestamp; freshness source-of-truth.
freshness:
cadence: hourly
max_staleness: 2h
source_column: updated_at
volume:
min_per_day: 100
max_per_day: 1000000
volatility: cyclical
recovery_action: |
Investigate ingestion pipeline at <runbook-url> if volume falls outside bounds for >2 cycles.
distribution:
- column: status
rule: accepted_values
values: [placed, shipped, completed, returned]
- column: discount_pct
rule: range
range: [0, 100]
- column: cancellation_rate
rule: rolling_window
window: 7d
max: 0.05
ownership:
producer_team: data-platform
owner: '@data-platform-oncall'
consumers:
- dbt: marts/orders_summary
- dashboard: 'Order Health'
- service: shipping-microservice
versioning: |
Breaking changes coordinated via #data-contracts Slack 14d in advance.When reading a data PRD:
pii: tag, even pii: none.
Force the data-product author to confirm; PII handling drives
downstream architecture.The agent never fabricates contract fields. Every gap becomes an explicit question:
## Contract gaps (HUMAN INPUT REQUIRED)
| Section | Field | Question |
|---------------|------------------------|--------------------------------------------------------------------------|
| schema | `customer_phone.pii` | Direct PII (yes - phone numbers are PII per most jurisdictions). Confirm. |
| freshness | `cadence` | PRD says "fresh data" - daily? hourly? real-time? Each implies a different gate. |
| volume | `max_per_day` | Not specified; required to set a `row_count between` assertion. |
| distribution | `payment_method` | What's the accepted-value set? PRD lists four; are there more (e.g. "apple_pay" added recently)? |Until the gaps are filled, the contract is incomplete and the test suite cannot be generated.
Three worked examples (PRD to contract, minimal source with a gap list, and refactor of an existing dataset) are in references/examples.md.
| Anti-pattern | Why it fails | Fix |
|---|---|---|
Auto-tagging every column pii: none | Misses real PII; downstream ungoverned. | Force the author to make the call; default to "needs review" rather than "none". |
| Generic freshness "real-time" | Ambiguous; "real-time" varies from <100ms to <1min by team. | Quantify: cadence: continuous, max_staleness: 60s. |
| Distribution rules without a window | "Cancellation rate ≤5%" - over what window? Lifetime? | Always specify a window: rolling_window: 7d. |
| Skipping Ownership | A contract without an owner is a wishlist; nobody's on the hook. | Require ownership before declaring the contract complete. |
non-functional-requirement-extractor, in the qa-shift-left
plugin) - for the underlying observability heuristic.dbt-testing, great-expectations, soda-checks -
the downstream consumers of this skill's output.data-quality-conventions - naming and threshold conventions referenced from the contract.