The three flows

import asyncio
from pydantic import BaseModel
from awaithumans import verify_document


class Invoice(BaseModel):
    invoice_number: str
    total_cents: int


async def main() -> None:
    # Whatever you got out of your OCR / scraper / earlier pipeline step.
    my_extraction = Invoice(invoice_number="INV-0042", total_cents=12500)

    result = await verify_document(
        document_path="invoice.pdf",
        task_description="Confirm or correct the invoice number and total.",
        response_schema=Invoice,
        prior_extraction=my_extraction,    # Flow A signal
    )

    print(f"Reviewer returned: {result}")


asyncio.run(main())

import asyncio
from pydantic import BaseModel
from awaithumans import verify_document
from awaithumans.providers import OpenAIExtraction


class Receipt(BaseModel):
    vendor: str
    total_cents: int
    purchase_date: str   # ISO 8601


async def main() -> None:
    result = await verify_document(
        document_path="receipt.png",
        task_description="Extract vendor, total in cents, and purchase date.",
        response_schema=Receipt,
        extraction=OpenAIExtraction(             # Flow B signal
            model="gpt-4o",
            prompt=(
                "Read this receipt. Return vendor name, total in cents "
                "(integer), and purchase date in ISO 8601."
            ),
        ),
    )

    print(result.vendor, result.total_cents, result.purchase_date)


asyncio.run(main())

import asyncio
from pydantic import BaseModel
from awaithumans import verify_document, VerifierConfig


class ContractClause(BaseModel):
    parties: list[str]
    effective_date: str
    auto_renew: bool


async def main() -> None:
    result = await verify_document(
        document_path="contract.pdf",
        task_description="Extract parties, effective date, and the auto-renew flag.",
        response_schema=ContractClause,
        verifier=VerifierConfig(                  # Flow C signal
            provider="claude",
            model="claude-3-5-sonnet-20241022",
            criteria=(
                "Verify that auto_renew is True only if the document "
                "contains 'auto-renew' or 'automatic renewal' near the "
                "termination clause."
            ),
        ),
    )

    print(result)


asyncio.run(main())