Get a weekly coaching note on each rep

from collections import defaultdict
from clickruntime import on_trigger, credentials, http, ai, notify

API = "https://yourcompany.my.salesforce.com/services/data/v61.0"

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    query = lambda q: http.get(f"{API}/query", headers=headers, params={"q": q}).json()["records"]
    activity = defaultdict(list)
    for t in query("SELECT Owner.Name, Subject, Status, ActivityDate FROM Task WHERE CreatedDate = THIS_WEEK"):
        activity[t["Owner"]["Name"]].append(f"Task: {t['Subject']} ({t['Status']})")
    for e in query("SELECT Owner.Name, Subject, StartDateTime FROM Event WHERE StartDateTime = THIS_WEEK"):
        activity[e["Owner"]["Name"]].append(f"Meeting: {e['Subject']}")
    notes = []
    for rep, items in sorted(activity.items()):
        note = ai.generate("\n".join(items)[:4000], max_output_tokens=150,
                           system="Write a 2-3 sentence supportive coaching note on this rep's week of sales activity.").text
        notes.append(f"{rep} ({len(items)} activities)\n{note}")
    notify.email_me("Weekly sales coaching notes", "\n\n".join(notes) or "No activity logged this week.")
    return {"reps": len(activity)}