Your property management inbox handles 68% of emails. Automatically.

async def process_email(self, email: EmailEvent) -> Decision:
    # Step 1: Classify the incoming email
    classification = await self.classifier.classify(
        subject=email.subject,
        body=email.body,
        tenant_id=email.tenant_id,
    )

    # Step 2: Check semantic cache — similar past decisions cost nothing
    cached = await self.cache.lookup(
        category=classification.category,
        embedding=classification.embedding,
        threshold=0.92,
    )
    if cached:
        return cached.decision

    # Step 3: Judge validates before any auto-execution
    if classification.recommended_action == 'auto_respond':
        threshold = self.config.thresholds[classification.category]
        judgment = await self.judge.validate(
            email=email,
            classification=classification,
        )
        if judgment.confidence < threshold:
            # Below threshold — move to human review queue
            classification.recommended_action = 'queue_for_review'

    # Step 4: Execute the validated decision
    return await self.execute(email, classification)