Upload finished videos as private and email you to approve

import base64
import io
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from googleapiclient.http import MediaIoBaseUpload
from clickruntime import on_event, http, credentials, state

def api(name, version):
    return build(name, version, credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)

def send_gmail(to, subject, text):
    raw = base64.urlsafe_b64encode(f"To: {to}\r\nSubject: {subject}\r\nContent-Type: text/plain; charset=utf-8\r\n\r\n{text}".encode()).decode()
    api("gmail", "v1").users().messages().send(userId="me", body={"raw": raw}).execute()

@on_event
def handle(event):
    job = event.json or {}
    if state.get(f"done:{event.event_id}"):
        return {"duplicate": True}
    media = MediaIoBaseUpload(io.BytesIO(http.get(job["video_url"], timeout=120).content), mimetype="video/mp4", resumable=True)
    video = api("youtube", "v3").videos().insert(part="snippet,status", media_body=media, body={
        "snippet": {"title": job["title"][:100], "description": job.get("description", "")},
        "status": {"privacyStatus": "private"}}).execute()
    link = f"https://youtu.be/{video['id']}"
    send_gmail("you@example.com", f"Ready to review: {job['title']}",
               f"A new video is uploaded as private:\n{link}\n\nMake it public in YouTube Studio when you're happy with it.")
    state.set(f"done:{event.event_id}", video["id"])
    return {"video": video["id"]}