get_current_trace()

def get_current_trace() -> Trace | None

def get_current_trace_id() -> str | None

import logging
from rdk import observe, get_current_trace_id

logger = logging.getLogger(__name__)

@observe()
def process(query: str):
    trace_id = get_current_trace_id()
    logger.info("Processing query", extra={"trace_id": trace_id, "query": query})
    # LLM calls here

from fastapi import Response
from rdk import observe, get_current_trace_id

@app.post("/chat")
@observe(name="api-chat")
async def chat(request: ChatRequest, response: Response):
    trace_id = get_current_trace_id()
    if trace_id:
        response.headers["X-Trace-ID"] = trace_id
    # LLM calls here

from rdk import observe, get_current_trace

@observe(name="pipeline", user_id="user_123", tags=["prod"])
def pipeline(query: str):
    t = get_current_trace()
    if t:
        print(f"Trace: {t.id}, user: {t.user_id}, tags: {t.tags}")

from rdk import get_current_trace

t = get_current_trace()
print(t)  # None — no active trace