Custom Metadata

from rdk import observe

@observe(name="chat", tags=["production", "gpt-4", "high-priority"])
def chat(message: str) -> str:
    # ...

from rdk import observe

@observe(
    name="process-order",
    metadata={
        "order_type": "subscription",
        "plan": "enterprise",
        "region": "us-west-2",
    }
)
def process_order(order_id: str) -> dict:
    # ...

from rdk import observe

@observe(name="chat", user_id="user_12345")
def chat(user_id: str, message: str) -> str:
    # ...

# Or dynamically
@observe(name="chat")
def chat_dynamic(user_id: str, message: str) -> str:
    # User ID from function parameter
    # Would need to be set in metadata instead
    ...

from rdk import observe

@observe(name="chat", session_id="session_abc123")
def chat(message: str) -> str:
    # All calls in this session are linked
    ...

import uuid
from anthropic import Anthropic
from rdk import observe, shutdown

class ChatService:
    def __init__(self, user_id: str):
        self.user_id = user_id
        self.session_id = str(uuid.uuid4())
        self.client = Anthropic()

    @observe(
        name="chat-service",
        tags=["production", "chat"],
        metadata={"service": "customer-support"}
    )
    def chat(self, message: str) -> str:
        response = self.client.messages.create(
            model="claude-sonnet-4-6",
            max_tokens=1024,
            messages=[{"role": "user", "content": message}]
        )
        return response.content[0].text

# Usage
service = ChatService(user_id="user_123")
response = service.chat("Hello!")
shutdown()

from rdk import observe

def get_trace_config(request_id: str, **kwargs):
    return {
        "name": f"request-{request_id}",
        "tags": ["api"],
        "metadata": {"request_id": request_id}
    }

# Note: This pattern requires manual trace management
# See Manual Tracing for advanced use cases

-- Find all traces for a specific user
user_id = "user_123"

-- Find high-priority production traces
tags CONTAINS "production" AND tags CONTAINS "high-priority"

-- Find enterprise plan requests
metadata.plan = "enterprise"