Email assignees and leads about overdue Jira tickets

import base64
from email.mime.text import MIMEText
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from collections import defaultdict
from clickruntime import on_trigger, credentials, http, state

JIRA, SITE = "https://api.atlassian.com/ex/jira/your-cloud-id", "https://acme.atlassian.net/browse/"
adf = lambda text: {"type": "doc", "version": 1, "content": [{"type": "paragraph", "content": [{"type": "text", "text": text}]}]}

def jira(method, path, **kw):
    resp = http.request(method, JIRA + path, headers={"Authorization": f"Bearer {credentials.connection('jira', 'work')}", "Accept": "application/json"}, **kw)
    return resp.raise_for_status() or (resp.json() if resp.content else None)
gmail = lambda: build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()

def send(to, subject, body, cc=None):
    msg = MIMEText(body)
    msg["To"], msg["Subject"] = to, subject
    if cc: msg["Cc"] = cc
    gmail().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()

LEADS = {"sam@acme.example": "lead.ops@acme.example"}

@on_trigger
def run(event):
    issues = jira("POST", "/rest/api/3/search/jql", json={"jql": "project = OPS AND statusCategory != Done AND (duedate < now() OR status = Blocked)",
                  "fields": ["summary", "duedate", "status", "assignee"], "maxResults": 200})["issues"]
    yesterday = set(state.get("emailed") or [])
    by_person = defaultdict(list)
    for i in issues:
        a = i["fields"]["assignee"]
        if a and a.get("emailAddress") and i["key"] not in yesterday:
            by_person[a["emailAddress"]].append(f"{i['key']} {i['fields']['summary']} ({i['fields']['status']['name']}, due {i['fields'].get('duedate') or '-'}) {SITE}{i['key']}")
    for email, lines in by_person.items():
        send(email, f"{len(lines)} Jira tickets need attention", "These tickets are overdue or blocked:\n\n" + "\n".join(lines)
             + "\n\nPlease update the due date or let your lead know what is in the way.", cc=LEADS.get(email))
    state.set("emailed", sorted({k.split()[0] for ls in by_person.values() for k in ls}))
    return {"people": len(by_person)}