graph TD
    A[Incoming Prospect Query] --> B[Waterfall Enrichment Orchestrator]
    B --> C{Primary Graph Hit?}
    C -->|Yes| D[Parse Firmographics & Direct Work Email]
    C -->|No / Incomplete| E{Secondary Exchange Hit?}
    E -->|Yes| F[Fill Missing Tech Stack & Pattern Email]
    E -->|No| G[Tertiary Registry Fallback]
    D --> H[Email Syntax & MX Deliverability Filter]
    F --> H
    G --> H
    H --> I[Unified High-Confidence Prospect Record]

from client import WaterfallEnrichmentOrchestrator

orchestrator = WaterfallEnrichmentOrchestrator()
prospect = orchestrator.enrich_prospect({
    "first_name": "Alex",
    "last_name": "Chen",
    "title": "CTO",
    "domain": "acmesystems.io"
})
print(prospect["target_contact"]["email"])