Sse

interfaces.fetch_request.sse

Summary

Fetch request SSE handlers — real-time progress events and ambiguity listing for a given fetch request. Events are streamed via an SSE bus; ambiguities are queried directly from the ambiguity service.

Functions

list_ambiguities `async`

list_ambiguities(request: Request, id: str)

List pending ambiguities for a fetch request.

Parameters:

Name	Type	Description	Default
`request`	`Request`	Incoming HTTP request; carries app.state.db_resources.	required
`id`	`str`	Fetch request id.	required

Returns:

Name	Type	Description
`list`		Pending ambiguity documents from the ambiguity service.

stream_fetch_events `async`

stream_fetch_events(request: Request, id: str)

Stream progress events for a fetch request as server-sent events.

If the SSE bus is not configured on app.state.db_resources an empty events list is returned. Otherwise a text/event-stream response is yielded, polling the bus every 500 ms until the client disconnects.