Email me Stripe subscriptions renewing next week

import time
import stripe
from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, notify, report_fetched

@on_trigger
def run(event):
    stripe.api_key = credentials.secret("STRIPE_API_KEY")
    now, cutoff = time.time(), time.time() + 7 * 86400
    rows = []
    for sub in stripe.Subscription.list(status="active", limit=100, expand=["data.customer"]).auto_paging_iter():
        items = sub["items"]["data"]
        end = items[0]["current_period_end"] if "current_period_end" in items[0] else sub.get("current_period_end")
        if sub.cancel_at_period_end or not (now <= end <= cutoff):
            continue
        amount = sum((i["price"]["unit_amount"] or 0) * (i.get("quantity") or 1) for i in items) / 100
        rows.append((items[0]["price"]["recurring"]["interval"], end, sub.customer.email, amount, sub.currency.upper()))
    report_fetched(len(rows))
    if not rows:
        return {"renewals": 0}
    fmt = lambda r: f"- {datetime.fromtimestamp(r[1], timezone.utc):%a %d %b} · {r[2]} · {r[3]:,.2f} {r[4]}"
    annual = sorted((r for r in rows if r[0] == "year"), key=lambda r: r[1])
    other = sorted((r for r in rows if r[0] != "year"), key=lambda r: r[1])
    total = sum(r[3] for r in rows)
    body = ("Annual:\n" + ("\n".join(map(fmt, annual)) or "- none") +
            f"\n\nMonthly and other ({len(other)}):\n" + ("\n".join(map(fmt, other)) or "- none") +
            f"\n\nTotal: {total:,.2f} {rows[0][4]}")
    notify.email_me(f"{len(rows)} Stripe renewals next week, {total:,.2f} {rows[0][4]}", body)
    return {"renewals": len(rows)}