Get an email when deals start to stall

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import date
from clickruntime import on_trigger, credentials, http, state
ME, INSTANCE = "me@northwind.example", "https://yourcompany.my.salesforce.com"
def send(subject, body):
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, subject
    msg.set_content(body)
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    opps = http.get(f"{INSTANCE}/services/data/v61.0/query", headers=headers, params={"q": "SELECT Id, Name, Amount, StageName, CloseDate, "
                    "PushCount, LastActivityDate, NextStep FROM Opportunity WHERE IsClosed = false LIMIT 500"}).json()["records"]
    flagged = []
    for o in opps:
        reasons = [why for hit, why in [(o["CloseDate"] < date.today().isoformat(), "close date has passed"),
                   ((o["PushCount"] or 0) >= 2, f"close date pushed {o['PushCount']} times"),
                   ((date.today() - date.fromisoformat(o["LastActivityDate"] or "2000-01-01")).days > 21, "no activity in 3 weeks"), (not o["NextStep"], "no next step")] if hit]
        if len(reasons) >= 2:
            flagged.append((o, reasons))
    new = [(o, r) for o, r in flagged if o["Id"] not in set(state.get("sent") or [])]
    if new:
        send(f"{len(new)} deals look at risk", "\n\n".join(f"{o['Name']} ({o['StageName']}, {o['Amount']}): {'; '.join(r)}\n{INSTANCE}/{o['Id']}" for o, r in new))
    state.set("sent", [o["Id"] for o, _ in flagged])
    return {"risky": len(flagged), "emailed": len(new)}