Span

class Span(CamelModel):
    id: str
    trace_id: str
    parent_id: str | None
    name: str
    type: SpanType
    input: dict | None
    output: dict | None
    model: str | None
    start_time: int
    end_time: int | None
    duration: int | None
    token_usage: TokenUsage | None
    metadata: dict
    status: SpanStatus
    error: SpanError | None
    tags: list[str]
    user_id: str | None
    session_id: str | None
    version: str | None

class SpanType(str, Enum):
    LLM = "LLM"           # Language model calls
    CHAIN = "CHAIN"       # Orchestration logic
    TOOL = "TOOL"         # Tool/function execution
    FUNCTION = "FUNCTION" # Custom function spans

class SpanStatus(str, Enum):
    RUNNING = "RUNNING"   # In progress
    SUCCESS = "SUCCESS"   # Completed successfully
    ERROR = "ERROR"       # Failed with error

span.complete(
    output={"result": "success"},
    token_usage=TokenUsage(
        prompt_tokens=100,
        completion_tokens=50,
        total_tokens=150
    )
)

span.fail(
    error_message="API timeout",
    stack="Traceback (most recent call last)..."  # optional
)

from rdk import observe, span
from rdk.models import SpanType

@observe()
def my_pipeline(query: str):
    with span("my-operation", span_type=SpanType.FUNCTION, input_data={"query": query}) as s:
        result = do_work(query)
        s.metadata["result_size"] = len(result)
    return result

{
  "id": "550e8400-e29b-41d4-a716-446655440001",
  "traceId": "550e8400-e29b-41d4-a716-446655440000",
  "parentId": null,
  "name": "anthropic.messages.create",
  "type": "LLM",
  "input": {"messages": [...]},
  "output": {"content": "..."},
  "model": "claude-sonnet-4-6",
  "startTime": 1708444800000,
  "endTime": 1708444801500,
  "duration": 1500,
  "tokenUsage": {
    "promptTokens": 100,
    "completionTokens": 50,
    "totalTokens": 150
  },
  "metadata": {"provider": "anthropic"},
  "status": "SUCCESS",
  "error": null,
  "tags": ["production"]
}