Stream Chat Progress

Stream real-time progress for a chat job using Server-Sent Events (SSE).

Opens an SSE connection that streams events as the AI processes your request. Use this with the job_id returned from POST /v1/chat/async.

Event types:

‘intermediate’: Progress updates during processing (content, sequence, timestamp).
‘proposed_change_batch’: The batch of document changes proposed for review, delivered as one event carrying changes[] (emitted when approval_mode is ‘ask_every_time’). Changes are always delivered as a batch via this event.
‘document_sync’: Chunk-id sync emitted before the agent runs, so changes can reference stable ids.
‘continue_prompt’: A pause on a large edit, asking whether to continue or stop.
‘documents_changed’: Signals that one or more documents were auto-applied (with per-document change counts and changed chunk ids).
‘model_fallback’: Notice that the request automatically failed over to another model tier.
‘final’: Processing complete. Contains the full result with AI response and document changes.
‘usage’: Billing data emitted after ‘final’ (monthly_used, monthly_limit, monthly_remaining).
‘error’: An error occurred (job failed, cancelled, or not found).

Authentication: Pass a token or api_key as a query parameter (required for EventSource which cannot set headers).

GET

chat

{session_id}

stream

Stream Chat Progress

curl --request GET \
  --url https://api.example.com/v1/chat/{session_id}/stream

import requests

url = "https://api.example.com/v1/chat/{session_id}/stream"

response = requests.get(url)

print(response.text)

const options = {method: 'GET'};

fetch('https://api.example.com/v1/chat/{session_id}/stream', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.example.com/v1/chat/{session_id}/stream",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.example.com/v1/chat/{session_id}/stream"

	req, _ := http.NewRequest("GET", url, nil)

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.example.com/v1/chat/{session_id}/stream")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.example.com/v1/chat/{session_id}/stream")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)

response = http.request(request)
puts response.read_body

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

Headers

authorization

string | null

Path Parameters

session_id

string

required

Query Parameters

job_id

string

required

Job ID to stream progress for

last_sequence

integer

default:0

SSE Last-Event-ID resume: only replay intermediate responses with sequence > this. Reconnects pass the highest sequence already processed so old events are NOT re-emitted; default 0 = full history.

Required range: x >= 0

token

string

Authentication token (query parameter for EventSource compatibility)

api_key

string

API key (query parameter for EventSource compatibility)

Response

Successful Response

Approve or deny AI-proposed document changes one-by-one or in batch (HITL workflow).Used with chat_async when approval_mode='ask_every_time'. For each proposed change (with chunk_id and HTML diff), respond approved=true|false plus optional feedback for the AI to revise on. Approved changes apply atomically; denied changes are discarded; the AI may revise based on feedback in the next turn. Required for regulated workflows (legal, medical, compliance) where every AI edit must be reviewed before it touches the document. For single changes: set approved=true/false and optionally provide feedback. For batch decisions: provide a 'changes' array with per-change decisions. After approval, the job resumes processing and eventually reaches status=completed.

Stream Chat Progress

curl --request GET \
  --url https://api.example.com/v1/chat/{session_id}/stream

import requests

url = "https://api.example.com/v1/chat/{session_id}/stream"

response = requests.get(url)

print(response.text)

const options = {method: 'GET'};

fetch('https://api.example.com/v1/chat/{session_id}/stream', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.example.com/v1/chat/{session_id}/stream",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.example.com/v1/chat/{session_id}/stream"

	req, _ := http.NewRequest("GET", url, nil)

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.example.com/v1/chat/{session_id}/stream")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.example.com/v1/chat/{session_id}/stream")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)

response = http.request(request)
puts response.read_body

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

v1

users

promo

uploads

agents

API Reference

mcp

Stream Chat Progress

Headers

Path Parameters

Query Parameters

Response