Data Flow

Producers on the left, the governed store in the middle, registered consumers on the right. DataForge is the upstream governance layer your AWS stack subscribes to. Hover a consumer to light up the workflow that produces what it ingests.

Sources

PIES / ACESnational feed

Parts Masterprivate label

Perfect Stopprivate label

Supplier PDFsextracted

Engine

DataForge Engine

extractnormalizecross-refgoldentrustclassifygenerate

confirmed → published · held ✕ → HITL

Governed store

Golden Recordsversioned · v5 · confirmed only

change feed: new / updated / withdrawn

Consumers

RAG indexpush · v5

Bedrock KBpush · v5

Redshiftpull · v5

Merchant feedpush · v5 · ← Brand Refresh

Site searchpush · v5 · ← Search Aug

Workflows drive runs through the engine:

A Name Templatesenrichment → all consumers

B Brand Refresh→ Merchant feed

D Search Aug→ Site search

Governance (off the distribution path):

C Vendor Scorecard→ supplier-trust + a human report

C produces nothing a system consumer subscribes to — which is why it isn't a workflow.

A enriches the store (fan-out, no pipe). B and D project from the store to one named consumer each — the visible pipes. C governs the trust that gates what ever reaches the store.