curl --request GET \
--url https://api.example.com/api/tasks/{task_id}/streamimport requests
url = "https://api.example.com/api/tasks/{task_id}/stream"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/api/tasks/{task_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/api/tasks/{task_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/api/tasks/{task_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/api/tasks/{task_id}/stream")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/api/tasks/{task_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>",
"ctx": {},
"input": "<unknown>"
}
]
}Reconnect Task Stream
Reconnect to an active SSE stream for a task. If a stream is currently in progress (or recently finished), replays all buffered events and then subscribes to live events until the stream ends. Returns 204 if no active stream exists for this task.
Uses Redis Streams for replay (XRANGE) and live following (XREAD BLOCK). This is race-condition-free: XRANGE returns all events up to now, then XREAD picks up exactly where XRANGE left off using the last event ID. Keepalive events are sent every 15s during live following to prevent proxy/client disconnects.
after: optional Redis Stream id (as returned in
TaskMessageResponse.last_event_id). If present, only events
strictly after this id are replayed — this lets a reconnecting
client combine a DB snapshot with a live delta without duplicating
content already persisted. If the cursor has fallen off the buffer
the response contains a single {type: "resync_required"} SSE event
and the client should refetch /messages as the source of truth.
curl --request GET \
--url https://api.example.com/api/tasks/{task_id}/streamimport requests
url = "https://api.example.com/api/tasks/{task_id}/stream"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/api/tasks/{task_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/api/tasks/{task_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/api/tasks/{task_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/api/tasks/{task_id}/stream")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/api/tasks/{task_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>",
"ctx": {},
"input": "<unknown>"
}
]
}