TealReliability

pip install tealtiger

import asyncio
from tealtiger import TealEngine, TealReliability

engine = TealEngine(
    policy={
        "reliability": {
            "retry_budget": 3,
            "circuit_threshold": 5,
            "fallback_model": "gpt-3.5-turbo",
            "degrade_on_timeout": True,
        }
    },
    modules=[TealReliability()],
)

async def main():
    decision = await engine.evaluate(
        request={"model": "gpt-4", "retry_count": 4},
        ctx={"correlation_id": "req-001"},
    )

    print(decision.action)        # "DENY"
    print(decision.reason_codes)  # ["RETRY_BUDGET_EXCEEDED"]

asyncio.run(main())

engine = TealEngine(
    policy={
        "reliability": {
            # Maximum retry attempts before denial
            "retry_budget": 3,
            # Consecutive failures before circuit opens
            "circuit_threshold": 5,
            # Time before circuit transitions to half-open (ms)
            "circuit_reset_timeout": 30000,
            # Ordered fallback models
            "fallback_chain": ["gpt-4o-mini", "gpt-3.5-turbo"],
            # Degrade instead of deny on timeout
            "degrade_on_timeout": True,
            # Maximum latency before degradation (ms)
            "latency_threshold": 5000,
        }
    },
    modules=[TealReliability()],
)

decision = await engine.evaluate(
    request={"model": "gpt-4", "retry_count": 4},  # budget is 3
    ctx={"correlation_id": "req-001"},
)

# decision.action == "DENY"
# decision.reason_codes == ["RETRY_BUDGET_EXCEEDED"]

# Circuit is open after 5 consecutive failures
decision = await engine.evaluate(
    request={"model": "gpt-4"},
    ctx={"correlation_id": "req-002"},
)

# decision.action == "DENY"
# decision.reason_codes == ["CIRCUIT_OPEN"]

engine = TealEngine(
    policy={
        "reliability": {
            "circuit_threshold": 3,
            "fallback_chain": ["gpt-4o-mini", "gpt-3.5-turbo"],
        }
    },
    modules=[TealReliability()],
)

decision = await engine.evaluate(
    request={"model": "gpt-4"},  # circuit is open
    ctx={"correlation_id": "req-003"},
)

# decision.action == "DEGRADE"
# decision.reason_codes == ["FALLBACK_TRIGGERED"]
# decision.metadata["fallback_model"] == "gpt-4o-mini"

decision = await engine.evaluate(
    request={"model": "gpt-4", "latency_ms": 6000},  # exceeds 5000ms threshold
    ctx={"correlation_id": "req-004"},
)

# decision.action == "DEGRADE"
# decision.reason_codes == ["DEGRADE_TRIGGERED"]

from tealtiger import TealReliability

reliability = TealReliability()

# Query circuit state programmatically
status = await reliability.get_circuit_status("gpt-4")
print(status.state)          # "open" | "closed" | "half_open"
print(status.failure_count)  # 7
print(status.last_failure)   # "2026-06-01T14:30:00Z"
print(status.reset_at)       # "2026-06-01T14:30:30Z"

# Manually reset a circuit (e.g., after provider recovery)
await reliability.reset_circuit("gpt-4")