Send each contact a personalised weekly tip through SendGrid

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, ai

TOPIC = "Keep receipts for every business expense, even small ones."

@on_trigger
def run(event):
    sg = {"Authorization": f"Bearer {credentials.secret('SENDGRID_API_KEY')}"}
    contacts = http.post("https://api.sendgrid.com/v3/marketing/contacts/search", headers=sg,
                         json={"query": "email LIKE '%'"}).json()["result"]
    tips, sent = {}, 0
    for c in contacts:
        industry = c.get("custom_fields", {}).get("industry", "small business")
        if industry not in tips:
            tips[industry] = ai.generate(f"Write a 3-sentence tip for a {industry} owner about: {TOPIC}", max_output_tokens=150).text
        r = http.post("https://api.sendgrid.com/v3/mail/send", headers=sg,
                      json={"from": {"email": "tips@northwind-books.example"}, "subject": "Your weekly tip",
                            "personalizations": [{"to": [{"email": c["email"]}]}],
                            "content": [{"type": "text/plain", "value": f"Hi {c.get('first_name', 'there')},\n\n{tips[industry]}"}]})
        sent += r.status_code == 202
    msg = EmailMessage()
    msg["To"], msg["Subject"] = "me", f"Weekly tip sent to {sent} of {len(contacts)} contacts"
    msg.set_content(f"Industries: {', '.join(tips)}")
    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()
    return {"sent": sent}