Langflow (tracing) | Respan Docs

Langflow is a visual framework by DataStax for building multi-agent and RAG applications. It provides a drag-and-drop interface for composing LLM pipelines with components for models, prompts, tools, and data sources. Langflow is built on LangChain, so Respan tracing uses respan-instrumentation-langchain to capture component runs, underlying LangChain calls, tools, retrievers, and LLM generations — and gateway routing through the OpenAI-compatible Respan endpoint.

Set up Respan

Create an account at platform.respan.ai and grab an API key.

Run npx @respan/cli setup to set up with your coding agent.

Use Respan Gateway

See Langflow gateway setup to route this integration through the Respan gateway.

Example projects

Example projects

Setup

Install packages

$ pip install respan-tracing respan-instrumentation-langchain langflow langchain langchain-openai python-dotenv

Set environment variables

$ export RESPAN_API_KEY="YOUR_RESPAN_API_KEY"
$ export RESPAN_BASE_URL="https://api.respan.ai/api"

RESPAN_API_KEY is used to export traces to Respan. Set OPENAI_API_KEY too when your Langflow components call provider-backed models.

Initialize and run

For custom Langflow component code, attach the Respan LangChain callback to each LangChain runnable invocation. Reuse one callback handler so independent component runs are grouped into one trace.

1 import os
2 from contextlib import suppress
3 
4 from langchain_core.runnables import RunnableLambda
5 from respan_instrumentation_langchain import add_respan_callback, get_callback_handler
6 from respan_tracing import RespanTelemetry
7 
8 telemetry = RespanTelemetry(
9     app_name="langflow-quickstart",
10     api_key=os.environ["RESPAN_API_KEY"],
11     base_url=os.getenv("RESPAN_BASE_URL", "https://api.respan.ai/api"),
12     is_auto_instrument=False,
13     is_batching_enabled=False,
14 )
15 
16 handler = get_callback_handler()
17 
18 def langflow_config(name: str):
19     return add_respan_callback(
20         {
21             "run_name": name,
22             "tags": ["respan-langchain-example", "langflow", name],
23             "metadata": {
24                 "example": name,
25                 "framework": "langflow",
26                 "langflow_component": "RoutingComponent",
27             },
28         },
29         handler,
30     )
31 
32 route_department = RunnableLambda(
33     lambda input: f"{input['department']}-workspace"
34 )
35 get_weather = RunnableLambda(
36     lambda input: f"It is sunny in {input['city']}."
37 )
38 
39 try:
40     route = route_department.invoke(
41         {"department": "security"},
42         config=langflow_config("langflow_route_department"),
43     )
44     weather = get_weather.invoke(
45         {"city": "Dublin"},
46         config=langflow_config("langflow_get_weather"),
47     )
48     print(f"{route}: {weather}")
49 finally:
50     with suppress(Exception):
51         telemetry.flush()

View your trace

Open the Traces page to see your Langflow workflow with component-level operations, LLM calls, retriever spans, and tool calls.

Configuration

Parameter	Type	Default	Description
`api_key`	`str \| None`	`None`	Falls back to `RESPAN_API_KEY` env var.
`base_url`	`str \| None`	`None`	Falls back to `RESPAN_BASE_URL` env var.
`instrumentations`	`list`	`[]`	Plugin instrumentations to activate, e.g. `LangChainInstrumentor()`.
`group_langflow_root_runs`	`bool`	`True` via `get_callback_handler()`	Groups independent Langflow component root runs into one trace.
`include_content`	`bool`	`True`	Includes component inputs and outputs on spans.
`include_metadata`	`bool`	`True`	Includes Langflow tags, metadata, and serialized runnable details.
`customer_identifier`	`str \| None`	`None`	Default customer identifier for all spans.
`metadata`	`dict \| None`	`None`	Default metadata attached to all spans.
`environment`	`str \| None`	`None`	Environment tag, e.g. `"production"`.

Attributes

In Respan()

Set defaults at initialization — these apply to all spans.

1 from respan import Respan
2 from respan_instrumentation_langchain import LangChainInstrumentor
3 
4 respan = Respan(
5     instrumentations=[LangChainInstrumentor()],
6     customer_identifier="user_123",
7     metadata={"service": "langflow-api", "version": "1.0.0"},
8 )

With propagate_attributes

Override per-request using a context scope.

1 from langflow.load import run_flow_from_json
2 from respan import propagate_attributes
3 
4 def handle_request(user_id: str, question: str):
5     with propagate_attributes(
6         customer_identifier=user_id,
7         thread_identifier="conv_abc_123",
8         metadata={"plan": "pro"},
9     ):
10         result = run_flow_from_json(flow="flow.json", input_value=question)
11         print(result)

Attribute	Type	Description
`customer_identifier`	`str`	Identifies the end user in Respan analytics.
`thread_identifier`	`str`	Groups related messages into a conversation.
`metadata`	`dict`	Custom key-value pairs. Merged with default metadata.

Decorators (optional)

Decorators are not required. Langflow runs are traced through LangChain callbacks. Use @workflow and @task (Python) or withWorkflow and withTask (TypeScript) when you want to group one or more flow executions inside a named application workflow.

1 from respan import workflow, task
2 
3 @task(name="run_langflow_flow")
4 def run_langflow_flow(question: str):
5     return run_flow_from_json(flow="flow.json", input_value=question)
6 
7 @workflow(name="langflow_request")
8 def pipeline(question: str):
9     print(run_langflow_flow(question))
10 
11 pipeline("What is the meaning of life?")
12 respan.flush()

Examples

Custom component callback grouping

Use one callback handler for the component invocation so multiple LangChain calls in the same custom component share a trace.

1 from respan_instrumentation_langchain import add_respan_callback, get_callback_handler
2 
3 handler = get_callback_handler()
4 config = add_respan_callback(
5     {
6         "run_name": "langflow_component",
7         "tags": ["langflow", "custom-component"],
8         "metadata": {
9             "framework": "langflow",
10             "langflow_component": "RoutingComponent",
11         },
12     },
13     handler,
14 )
15 
16 result = chain.invoke({"question": "Route this request"}, config=config)

Exported flows

Exported flows can be run normally after Respan telemetry is initialized. For custom components inside the flow, pass add_respan_callback(...) when invoking LangChain runnables.

1 from langflow.load import run_flow_from_json
2 
3 result = run_flow_from_json(
4     flow="path/to/your/flow.json",
5     input_value="Summarize this support request.",
6 )
7 print(result)