import json
import os
import httpx
payload = {"query": "What changed in battery recycling this year?", "mode": "deep", "stream": True}
with httpx.stream(
"POST",
"https://agent.tinyfish.ai/v1/automation/run-research",
headers={"X-API-Key": os.environ["TINYFISH_API_KEY"]},
json=payload,
timeout=2700,
) as response:
response.raise_for_status()
for line in response.iter_lines():
if not line.startswith("data: "):
continue
event = json.loads(line[6:])
if event["event"] == "synthesis_delta":
print(event["delta"], end="", flush=True)
elif event["event"] == "done":
break