Find keywords spending with no conversions

from clickruntime import on_trigger, credentials, http, notify

CUSTOMER_ID = "1234567890"

def gaql(query):
    headers = {"Authorization": f"Bearer {credentials.connection('google', 'ads')}",
               "developer-token": credentials.secret("GOOGLE_ADS_DEVELOPER_TOKEN")}
    batches = http.post(f"https://googleads.googleapis.com/v21/customers/{CUSTOMER_ID}/googleAds:searchStream",
                        headers=headers, json={"query": query}).json()
    return [row for b in batches for row in b.get("results", [])]


MIN_COST = 50
PAUSE = False  # set True to pause them automatically

@on_trigger
def run(event):
    rows = gaql("SELECT ad_group_criterion.resource_name, ad_group_criterion.keyword.text, campaign.name, "
                "metrics.cost_micros, metrics.conversions FROM keyword_view "
                "WHERE segments.date DURING LAST_30_DAYS AND ad_group_criterion.status = 'ENABLED'")
    waste = [r for r in rows if float(r["metrics"].get("conversions", 0)) == 0
             and int(r["metrics"].get("costMicros", 0)) / 1e6 >= MIN_COST]
    if not waste:
        return {"keywords": 0}
    if PAUSE:
        http.post(f"https://googleads.googleapis.com/v21/customers/{CUSTOMER_ID}/adGroupCriteria:mutate",
                  headers={"Authorization": f"Bearer {credentials.connection('google', 'ads')}",
                           "developer-token": credentials.secret("GOOGLE_ADS_DEVELOPER_TOKEN")},
                  json={"operations": [{"update": {"resourceName": r["adGroupCriterion"]["resourceName"], "status": "PAUSED"},
                                        "updateMask": "status"} for r in waste]})
    lines = [f"{r['adGroupCriterion']['keyword']['text']} ({r['campaign']['name']}): ${int(r['metrics']['costMicros']) / 1e6:,.2f}" for r in waste]
    notify.email_me(f"{len(waste)} keywords with no conversions in 30 days" + (" (paused)" if PAUSE else ""), "\n".join(lines))
    return {"keywords": len(waste), "paused": PAUSE}