Publish Execution Event

Publish a streaming event via event bus (multi-provider support).

This endpoint is used by workers to send real-time events (tool execution, status updates, etc.) that are streamed to the UI via SSE without waiting for Temporal workflow completion.

Supports multiple providers:

• Redis: List storage + pub/sub for SSE streaming
• HTTP: Webhook notifications
• WebSocket: Real-time push to connected clients
• NATS: High-performance message streaming

Events are stored in Redis list: execution::events TTL: 1 hour (events are temporary, final state persists in database)

POST /api/v1/executions/{execution_id}/events

Publish Execution Event

cURL

curl --request POST \
  --url https://control-plane.kubiya.ai/api/v1/executions/{execution_id}/events \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "event_type": "<string>",
  "data": {},
  "timestamp": "<string>"
}
'

422

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

Authorizations

Authorization · string · header · required

Enter your Kubiya API token (format: Bearer )

Path Parameters

execution_id · string · required

Body

application/json

Request to publish a streaming event to Redis for real-time UI updates

event_type · string · required

data · Data · object · required

timestamp · string | null

Response

202

application/json

Successful Response