Batches

import (
  "context"
  "fmt"
  phaseo "github.com/phaseoteam/Phaseo/packages/sdk/sdk-go/v2"
)

client := phaseo.New(apiKey, "https://api.phaseo.app/v1")
ctx := context.Background()

created, err := client.CreateBatch(ctx, map[string]interface{}{
  "model": "openai/gpt-5-mini",
  "prompts": []string{"Summarize this record.", "Classify this support ticket."},
  "system": "Be concise.",
  "max_tokens": 256,
  "completion_window": "24h",
  "session_id": "agent-run-42",
  "webhook_endpoint_id": "we_123",
})
if err != nil {
  panic(err)
}

status, err := client.RetrieveBatch(ctx, fmt.Sprint(created.(map[string]interface{})["id"]))
if err != nil {
  panic(err)
}

cancelling, err := client.CancelBatch(ctx, fmt.Sprint(created.(map[string]interface{})["id"]))
if err != nil {
  panic(err)
}

websocketURL, err := client.GetBatchWebSocketURL(
  fmt.Sprint(created.(map[string]interface{})["id"]),
  &phaseo.AsyncJobWebSocketOptions{IntervalMS: 1500},
)
if err != nil {
  panic(err)
}

fmt.Println(status)
fmt.Println(cancelling)
fmt.Println(websocketURL)