Query Stream

1 import requests 2 import json 3 4 BASE_URL = "https://api.runcaptain.com" 5 API_KEY = "your_api_key" 6 request_id = "your_request_id" # From query response 7 8 # Connect to SSE stream 9 response = requests.get( 10 f"{BASE_URL}/v2/streams/{request_id}", 11 headers={"Authorization": f"Bearer {API_KEY}"}, 12 stream=True, 13 timeout=120.0 14 ) 15 16 if response.status_code == 200: 17 for line in response.iter_lines(): 18 if line: 19 line_str = line.decode("utf-8") 20 if line_str.startswith("data: "): 21 data = line_str[6:] 22 try: 23 parsed = json.loads(data) 24 if parsed.get("type") == "stream_complete": 25 print("\nStream complete!") 26 break 27 except json.JSONDecodeError: 28 print(data, end="", flush=True)

Server-Sent Events (SSE) endpoint for streaming query responses.

The request_id is returned from POST /v2/collections/{collection_name}/query when stream: true.

Returns SSE stream with events:

Text chunks for the AI response
stream_complete event when done

Server-Sent Events (SSE) endpoint for streaming query responses. The request_id is returned from POST /v2/collections/{collection_name}/query when stream: true. Returns SSE stream with events: - Text chunks for the AI response - stream_complete event when done

Path parameters

request_idstringRequired

The request ID from the query response

Response

This endpoint returns an object.

Path parameters

Headers

Response

Errors