Sessions

from langfuse import observe, propagate_attributes   @observe() def process_request():  # Propagate session_id to all child observations  with propagate_attributes(session_id="your-session-id"):  # All nested observations automatically inherit session_id  result = process_chat_message()    return result

from langfuse import get_client, propagate_attributes   langfuse = get_client()   with langfuse.start_as_current_observation(  as_type="span",  name="process-chat-message" ) as root_span:  # Propagate session_id to all child observations  with propagate_attributes(session_id="chat-session-123"):  # All observations created here automatically have session_id  with root_span.start_as_current_observation(  as_type="generation",  name="generate-response",  model="gpt-4o"  ) as gen:  # This generation automatically has session_id  pass

import { startActiveObservation, propagateAttributes } from "@langfuse/tracing";   await startActiveObservation("context-manager", async (span) => {  span.update({  input: { query: "What is the capital of France?" },  });    // Propagate sessionId to all child observations  await propagateAttributes(  {  sessionId: "session-123",  },  async () => {  // All observations created here automatically have sessionId  // ... your logic ...  }  ); });

import { observe, propagateAttributes } from "@langfuse/tracing";   const processChatMessage = observe(  async (message: string) => {  // Propagate sessionId to all child observations  return await propagateAttributes({ sessionId: "session-123" }, async () => {  // All nested observations automatically inherit sessionId  const result = await processMessage(message);  return result;  });  },  { name: "process-chat-message" } );   const result = await processChatMessage("Hello!");

from langfuse import get_client, propagate_attributes from langfuse.openai import openai   langfuse = get_client()   with langfuse.start_as_current_observation(as_type="span", name="openai-call"):  # Propagate session_id to all observations including OpenAI generation  with propagate_attributes(session_id="your-session-id"):  completion = openai.chat.completions.create(  name="test-chat",  model="gpt-3.5-turbo",  messages=[  {"role": "system", "content": "You are a calculator."},  {"role": "user", "content": "1 + 1 = "}  ],  temperature=0,  )

from langfuse import get_client, propagate_attributes from langfuse.langchain import CallbackHandler   langfuse = get_client() handler = CallbackHandler()   with langfuse.start_as_current_observation(as_type="span", name="langchain-call"):  # Propagate session_id to all observations  with propagate_attributes(session_id="your-session-id"):  # Pass handler to the chain invocation  chain.invoke(  {"animal": "dog"},  config={"callbacks": [handler]},  )

import { startActiveObservation, propagateAttributes } from "@langfuse/tracing"; import { CallbackHandler } from "langfuse-langchain";   const langfuseHandler = new CallbackHandler();   await startActiveObservation("langchain-call", async () => {  // Propagate sessionId to all observations  await propagateAttributes(  {  sessionId: "your-session-id",  },  async () => {  // Pass handler to the chain invocation  await chain.invoke(  { input: "<user_input>" },  { callbacks: [langfuseHandler] }  );  }  ); });