Hear when a big deal starts looking risky

from slack_sdk import WebClient
from clickruntime import on_trigger, credentials, http, state, ai
INSTANCE = "https://yourcompany.my.salesforce.com"
API = f"{INSTANCE}/services/data/v61.0"

def soql(headers, q):
    return http.get(f"{API}/query", headers=headers, params={"q": q}).json()["records"]
SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "reason": {"type": "string"}},
          "required": ["score", "reason"]}
@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    deals = soql(headers, "SELECT Id, Name, Amount, StageName, CloseDate, PushCount, NextStep, LastActivityDate, "
                 "Owner.Email FROM Opportunity WHERE IsClosed = false AND Amount > 20000 ORDER BY Amount DESC LIMIT 40")
    slack = WebClient(token=credentials.connection("slack", "work"))
    scores, alerted = state.get("scores") or {}, 0
    for d in deals:
        r = ai.generate(f"Rate the risk of this deal slipping or being lost, 1 (safe) to 10, with a one-line reason.\n"
                        f"{d['Name']} | {d['Amount']} | {d['StageName']} | close {d['CloseDate']} | pushed {d['PushCount']} times | "
                        f"next step: {d['NextStep'] or 'none'} | last activity {d['LastActivityDate'] or 'never'}",
                        json_schema=SCHEMA, max_output_tokens=80).json
        before = scores.get(d["Id"])
        if before is not None and r["score"] - before >= 2:
            user = slack.users_lookupByEmail(email=d["Owner"]["Email"])["user"]["id"]
            slack.chat_postMessage(channel=user, text=f"Risk on <{INSTANCE}/{d['Id']}|{d['Name']}> went from "
                                                      f"{before} to {r['score']}/10: {r['reason']}")
            alerted += 1
        scores[d["Id"]] = r["score"]
    state.set("scores", scores)
    return {"scored": len(deals), "alerted": alerted}