Live artifacts

import json
import os

from gumloop import Gumloop

AGENT_ID = "your_agent_id"  # the Account Researcher agent

FORMAT = """Format the brief in Markdown exactly like this. Do not use em dashes.
First line: one sentence that says what the company is.
## What they sell
Two short bullets.
## Who they sell to
Two short bullets.
## Recent news
Three bullets. Start each with a date and a colon, for example "Sep 2, 2026: ...".
## Talking points
Three numbered points, each under 30 words."""

payload = json.loads(os.getenv("GUMLOOP_PAYLOAD", "{}"))
company = (payload.get("company") or "").strip()[:120]
pitch = (payload.get("pitch") or "").strip()[:300]
if not company:
    raise ValueError("Enter a company name.")

prompt = f"Write an account brief for {company}."
if pitch:
    prompt += f" Tailor the talking points to this offer: {pitch}."
prompt += "\n\n" + FORMAT

client = Gumloop()  # runs as the person viewing the page
resp = client.sessions.create(AGENT_ID, input=prompt, name=f"Account brief: {company}")
print(json.dumps({"session_id": resp.session.id}))

import json
import os
import time

from gumloop import Gumloop

payload = json.loads(os.getenv("GUMLOOP_PAYLOAD", "{}"))
session_id = payload.get("session_id")
if not session_id:
    raise ValueError("Missing session_id.")

client = Gumloop()
deadline = time.monotonic() + 60  # stay under the 90-second request limit
while True:
    session = client.sessions.retrieve(session_id).session
    if session.state in ("completed", "failed") or time.monotonic() > deadline:
        break
    time.sleep(3)


def text_of(message):
    # The final answer is the last text part; earlier parts are progress notes.
    texts = [p.get("text", "") for p in (message.parts or []) if p.get("type") == "text"]
    texts = [t for t in texts if t.strip()]
    return texts[-1] if texts else (message.content or "")


replies = [text_of(m) for m in (session.messages or []) if m.role != "user"]
replies = [r for r in replies if r.strip()]
print(json.dumps({
    "state": session.state,
    "name": session.name,
    "brief": replies[-1] if replies else "",
}))

import json

from gumloop import Gumloop

AGENT_ID = "your_agent_id"  # the Account Researcher agent

client = Gumloop()
page = client.sessions.list(AGENT_ID, type="api", page_size=8)
print(json.dumps([
    {"id": s.id, "name": s.name, "state": s.state, "created_at": str(s.created_at or "")}
    for s in page.sessions
    if (s.name or "").startswith("Account brief:")
]))

import json
import os

from gumloop import Gumloop

AGENT_ID = "your_agent_id"  # Account Researcher

FORMAT = """Reply with only a JSON object, no other text:
{"segment": "<industry and size, under 6 words>",
 "fit": <1 to 5, how well they fit the offer>,
 "reason": "<one plain sentence, under 18 words, no em dashes>"}"""

payload = json.loads(os.getenv("GUMLOOP_PAYLOAD", "{}"))
companies = [c.strip()[:80] for c in payload.get("companies", []) if c.strip()][:8]
offer = (payload.get("offer") or "").strip()[:300]
if not companies:
    raise ValueError("Add at least one company.")

client = Gumloop()  # runs as the person viewing the page
sessions = []
for company in companies:
    prompt = f"Qualify {company} as a sales lead for this offer: {offer}\n\n{FORMAT}"
    resp = client.sessions.create(AGENT_ID, input=prompt, name=f"Lead check: {company}")
    sessions.append({"company": company, "session_id": resp.session.id})
print(json.dumps(sessions))

import json
import os
import re
from datetime import datetime, timedelta

from gumloop import Gumloop

AGENT_ID = "your_agent_id"  # Account Researcher

payload = json.loads(os.getenv("GUMLOOP_PAYLOAD", "{}"))
client = Gumloop()

ids = payload.get("session_ids", [])[:8]
if not ids:
    # No run in progress: show the viewer's latest lead checks when the page opens.
    page = client.sessions.list(AGENT_ID, type="api", page_size=25)
    checks = [s for s in page.sessions if (s.name or "").startswith("Lead check: ")]
    times = [datetime.fromisoformat(str(s.created_at).replace("Z", "+00:00")) for s in checks]
    if checks:
        newest = max(times)
        # Keep only the most recent run: sessions started within 5 minutes of the newest one.
        ids = [s.id for s, t in zip(checks, times) if newest - t < timedelta(minutes=5)][:8]


def reply_text(session):
    for message in reversed(session.messages or []):
        if message.role == "user":
            continue
        texts = [p.get("text", "") for p in (message.parts or []) if p.get("type") == "text"]
        texts = [t for t in texts if t.strip()] or [message.content or ""]
        if texts[-1].strip():
            return texts[-1]
    return ""


results = []
for session_id in ids:
    session = client.sessions.retrieve(session_id).session
    row = {
        "session_id": session_id,
        "company": (session.name or "").removeprefix("Lead check: "),
        "state": session.state,
    }
    if session.state == "completed":
        match = re.search(r"\{.*\}", reply_text(session), re.S)
        try:
            row.update(json.loads(match.group(0)) if match else {})
        except ValueError:
            row["reason"] = "The agent didn't return a score."
    results.append(row)
print(json.dumps(results))