Use cheaper models with Meta Muse through an explicit Python policy.

incident_id = (qbash.inputs.get("incident_id") or "").strip()
service = (qbash.inputs.get("service") or "").strip()
signals = qbash.inputs.get("signals")
dry_run = qbash.inputs.get("dry_run", True)
if (not incident_id or len(incident_id) > 80
        or not all(ch.isalnum() or ch in "-_" for ch in incident_id)):
    raise ValueError("Provide a valid incident ID.")
if not 2 <= len(service) <= 120:
    raise ValueError("Provide a service name from 2 to 120 characters.")
if not isinstance(signals, list) or not 1 <= len(signals) <= 12:
    raise ValueError("Provide 1 to 12 incident signals.")
if any(not isinstance(item, str) or not 1 <= len(item.strip()) <= 500 for item in signals):
    raise ValueError("Every signal needs 1 to 500 characters.")
if not isinstance(dry_run, bool):
    raise ValueError("dry_run must be a boolean.")

investigation = qbash.tasks.run(
    "Incident Investigator",
    {
        "incident_id": incident_id,
        "service": service,
        "signals": [item.strip() for item in signals],
    },
)
if not isinstance(investigation, dict):
    raise ValueError("The investigator did not return an object.")
severity = investigation.get("severity")
summary = investigation.get("summary")
sources = investigation.get("sources")
next_steps = investigation.get("next_steps")
if severity not in {"low", "medium", "high", "critical"}:
    raise ValueError("The investigator returned an unknown severity.")
if not isinstance(summary, str) or not summary.strip():
    raise ValueError("The investigator returned no summary.")
if not isinstance(sources, list) or not 1 <= len(sources) <= 6:
    raise ValueError("The investigator must return 1 to 6 sources.")
if not isinstance(next_steps, list) or not 1 <= len(next_steps) <= 5:
    raise ValueError("The investigator must return 1 to 5 next steps.")

clean_sources = []
for source in sources:
    if not isinstance(source, dict):
        raise ValueError("Every source must be an object.")
    title = source.get("title")
    url = source.get("url")
    if not isinstance(title, str) or not 1 <= len(title.strip()) <= 160:
        raise ValueError("Every source needs a short title.")
    if not isinstance(url, str) or not url.startswith("https://") or len(url) > 500:
        raise ValueError("Every source needs an HTTPS URL.")
    clean_sources.append({"title": title.strip(), "url": url})
if any(not isinstance(item, str) or not item.strip() for item in next_steps):
    raise ValueError("Every next step must be text.")

def safe(value):
    return value.replace("&", "&amp;").replace("<", "&lt;").replace(">", "&gt;")

source_lines = [f"• {safe(item['title'])}: {item['url']}" for item in clean_sources]
step_lines = [f"• {safe(item.strip()[:240])}" for item in next_steps]
message = (
    f"*Incident {safe(incident_id)} · {safe(service)} · {severity.upper()}*\n"
    + safe(summary.strip()[:1200])
    + "\n\n*Sources*\n" + "\n".join(source_lines)
    + "\n\n*Proposed next steps*\n" + "\n".join(step_lines)
)
if not dry_run:
    qbash.checkpoint.get_or_set(
        f"incident-handoff:{incident_id}",
        lambda: qbash.integrations.slack.create_message(
            channel="C_INCIDENT_HANDOFFS", text=message,
        ),
    )

qbash.output({
    "incident_id": incident_id,
    "severity": severity,
    "dry_run": dry_run,
    "message": message,
    "source_urls": [item["url"] for item in clean_sources],
})