Enrich a contact list with Lusha and email the results

import csv, io
from clickruntime import on_trigger, credentials, notify, http, state

@on_trigger
def run(event):
    emails = state.get("prospect_emails") or []
    headers = {"api_key": credentials.secret("LUSHA_API_KEY")}
    out = io.StringIO()
    writer = csv.writer(out)
    writer.writerow(["email", "name", "title", "company", "phone"])
    for i in range(0, len(emails), 100):
        batch = [{"contactId": str(n), "email": e} for n, e in enumerate(emails[i:i + 100], start=i)]
        resp = http.post("https://api.lusha.com/v2/person", headers=headers, json={"contacts": batch})
        resp.raise_for_status()
        for c in batch:
            d = (resp.json()["contacts"].get(c["contactId"]) or {}).get("data") or {}
            phones = d.get("phoneNumbers") or [{}]
            writer.writerow([c["email"], d.get("fullName", ""), (d.get("jobTitle") or {}).get("title", ""),
                             (d.get("company") or {}).get("name", ""), phones[0].get("number", "")])
    notify.email_me(f"Lusha enrichment: {len(emails)} prospects", out.getvalue())
    return {"enriched": len(emails)}