Stream live agent_discourse events for the deal's in-flight memo run
GET
/api/canvas/{deal_id}/discourse/stream
const url = 'https://example.com/api/canvas/example/discourse/stream';const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};
try { const response = await fetch(url, options); const data = await response.json(); console.log(data);} catch (error) { console.error(error);}curl --request GET \ --url https://example.com/api/canvas/example/discourse/stream \ --header 'Authorization: Bearer <token>'Open an SSE stream of agent_discourse events for deal_id.
Each event is a JSON dict with at least id, thread_id, agent,
ts, and the original entry fields (stage, message, status,
tool, duration, etc. — whatever the producing subagent wrote).
The stream stays open for the lifetime of the workflow (or browser tab).
Browsers automatically reconnect with Last-Event-ID; the route replays
missed events from the publisher’s 100-entry / 2h ring before tailing
fresh pub/sub messages.
Authorizations
Section titled “Authorizations ”Parameters
Section titled “ Parameters ”Path Parameters
Section titled “Path Parameters ” deal_id
required
Deal Id
string
Responses
Section titled “ Responses ”Successful Response
Media type application/json
Example generated
exampleValidation Error
Media type application/json
HTTPValidationError
object
detail
Detail
Array<object>
ValidationErrorobject
loc
required
Location
Array
msg
required
Message
string
type
required
Error Type
string
input
Input
ctx
Context
object
Example generated
{ "detail": [ { "loc": [ "example" ], "msg": "example", "type": "example", "input": "example", "ctx": {} } ]}