Description
n8n-nodes-agent-langfuse




Two n8n community nodes that bring AI execution and Langfuse observability together, without extra nodes in your workflow.
- AI Agent + Langfuse runs the tool-calling agent, pulls its prompt from Langfuse and traces the whole thing.
- Decision Agent + Langfuse (new in 0.7.0) calls a decision model, one that returns a typed answer instead of text, and traces it with the cost the provider reported.
- Why this node?
- Decision Agent + Langfuse
- Quick Start
- Features
- Installation
- Setup
- Configuration (prompts, variables, metadata, node output)
- Examples
- Multiple Langfuse Projects
- Compatibility
- Upgrading
- Troubleshooting
- Development
- An HTTP Request node to fetch prompts from Langfuse API
- A Code node to extract the prompt content and model config
- The AI Agent node itself
- Manual configuration to pass tracing callbacks
The agent node brings AI Agent execution and Langfuse together in a single node. Select prompts from Langfuse, override models dynamically, and get full tracing, all without extra nodes in your workflow.
> First n8n node to combine Agent V3 architecture with native Langfuse prompt management and tracing.
Contents
Why this node?
If you use n8n’s AI Agent with Langfuse, you currently need:
This node replaces all of that with one node. Select your Langfuse prompt from a dropdown, and the node handles everything: prompt injection, model override, tracing, and metadata.
vs. other Langfuse nodes
Two kinds of node exist in this space: agent nodes (run the tool-calling agent and trace it) and the official Langfuse node (fetches prompts, no agent). This node is the agent kind. What sets it apart is the depth of the Langfuse integration: prompt management wired into the node UI, and tracing built on the v5 SDK with strict per-credential isolation.
| | This node | Other agent + Langfuse nodes | Official Langfuse node |
|—|———–|——————————|————————|
| Runs the tool-calling agent (Agent V3, LangChain 1.x) | Yes | Yes | No (prompt fetch only) |
| Prompt selector with auto-loaded {{variables}}, generations linked to the prompt version | Yes | No | Fetch by name, no variables UI |
| Model and temperature from the prompt config | Yes | No | N/A |
| Langfuse SDK v5 (OpenTelemetry), no trace leak across credentials | Yes | No (v3 legacy callback) | N/A |
| Trace id + URL on the output, Parse Output as JSON | Yes | No | N/A |
| Human in the loop | No (rorubyy’s node has it) | Yes | No |
Decision Agent + Langfuse
Some models do not generate text. You give them a state and a set of typed questions, and they answer
with a label or a probability, calibrated. Added in 0.7.0, this second node calls one and puts the call
in Langfuse, where an HTTP Request node would leave it outside your observability.
Questions come in three types:
| Type | Answers with | Criteria |
|—|—|—|
| Yes/No (Noul) | the probability of yes | none |
| Choice | one of your labels, plus the probability of each | a map of label to description |
| Score | a number over your ordered levels, plus a legend | the levels, in order |
Output. Each answer lands on the item under its own name, with the raw answers and confidences
alongside, so a plain IF node can branch on them:
{
"isbillingissue": 0.99,
"area": "billing",
"urgency": 2.9,
"answers": { "area": { "type": "choice", "choice": "billing",
"probabilities": { "billing": 1, "bug": 0 }, "confidence": 1 } },
"confidences": { "area": 1, "urgency": 0.9 },
"usage": { "inputtokens": 500, "outputtokens": 81, "cost": 0.000021 },
"langfuseTrace": { "id": "...", "url": "..." }
}
The trace carries the provider’s cost. Langfuse honours a provided cost over its own price table,
so the number on your dashboard is the one that was billed, not an estimate from a model lookup.
Credentials. Two, both always required: your Langfuse credential for the trace, and n8n’s own
OpenRouter credential for the call. Only the API key is read from it; the endpoint origin is derived
from its base url, so a proxy or a self-hosted gateway keeps working.
Before you use it
same request can change an answer. Confidence predicts that well, so a hybrid works: decide with the
model above a confidence threshold and fall back to an LLM below it. That is what the Confident branch does in the screenshot above.
enough?
/api/alpha/decisions). Pin the model version rather than a moving alias,and keep a fallback path in the workflow.
Quick Start
1. Install the node: Settings > Community Nodes > Install > n8n-nodes-agent-langfuse
2. Create an Agent Langfuse API credential with your Base URL, Public Key, and Secret Key
3. Add “AI Agent + Langfuse” to your workflow and connect a Chat Model
4. Select a Langfuse prompt from the dropdown
5. Execute: the agent runs with your prompt and traces to Langfuse automatically
Features
AI Agent + Langfuse
{{variables}} in your Langfuse prompt auto-load as editable fields in the node. Values support n8n expressions and are validated before any LLM call. - , so traces are easy to disambiguate when you reuse a node across workflows.Decision Agent + Langfuse
Installation
Community Nodes (Recommended)
1. Go to Settings > Community Nodes
2. Click Install
3. Enter n8n-nodes-agent-langfuse
4. Click Install
Manual Installation
cd ~/.n8n/nodes
npm install n8n-nodes-agent-langfuse
Restart n8n
Setup
1. Create Langfuse Credentials
1. In n8n, go to Credentials > New Credential
2. Search for Agent Langfuse API
3. Fill in:
– Base URL: Your Langfuse instance URL (e.g., https://cloud.langfuse.com or your self-hosted URL)
– Public Key: Your Langfuse project public key
– Secret Key: Your Langfuse project secret key
4. Click Test to verify the connection. You should see “Connection tested successfully”
> Tip: Find your keys in Langfuse under Settings > Projects > [Your Project] > API Keys
2. Configure the Node
1. Search for “AI Agent + Langfuse” in the node panel
2. Drag it into your workflow
3. Connect a Chat Model (OpenAI, OpenRouter, Anthropic, etc.) to the “Chat Model” input
4. Select your Langfuse credential
5. Choose your prompt from the dropdown
6. Optionally connect Tools, Memory, or Output Parser
Configuration
Prompt Source
| Option | Description |
|——–|————-|
| Langfuse Prompt | Select a production prompt from your Langfuse project. The dropdown shows all chat-type prompts. |
| Manual | Write the system message directly in the node (standard behavior). |
Langfuse Prompt Selector
The dropdown fetches all production chat-type prompts from your Langfuse project (every page of the list). Select one, and the node automatically:
The node uses the prompt’s first system message and, when present, its first user message (which then becomes the human turn). Additional turns, such as few-shot examples, are not sent to the model; the node logs a warning naming how many were ignored.
Model Source (when using Langfuse Prompt)
| Option | Description |
|——–|————-|
| From Langfuse | Uses the model and temperature from your Langfuse prompt’s config. The connected Chat Model provides the provider and API key; only the model name is overridden. |
| Manual Override | Uses the model exactly as configured in the connected Chat Model node. |
> How model override works: When you select “From Langfuse”, the node creates a new LLM instance using the same provider and API key from your connected Chat Model, but with the model name from Langfuse. For example, if your Chat Model is configured with OpenRouter and gpt-4.1-mini, but your Langfuse prompt has model: "openai/gpt-5-nano", the node will call OpenRouter with gpt-5-nano. Change models in Langfuse, with no workflow changes needed.
Prompt Variables
Langfuse chat prompts can contain {{variable}} placeholders in their system and user messages. The node reads the selected prompt and auto-populates one input field per {{variable}}, so there is no need to type variable names by hand.
{{var}} referenced by that prompt’s system and user messages.{{ $json.customer }}).{{variables}}, the mapper shows a notice and there’s nothing to fill in.Missing variables throw a NodeOperationError before any LLM call is made, listing exactly which names need values. Empty-string values count as missing. This runtime check is the real guard (the mapper marks fields required but won’t hard-block execution).
#### How the Langfuse user message interacts with Text / chatInput
| Langfuse prompt contains… | Result |
|—|—|
| system only | Compiled system message is used. Prompt Type / Text (or chatInput) drives the human turn, as before. |
| system + user | Compiled system message is used. Compiled user message replaces the human turn; Prompt Type / Text field is ignored. Map any free-form input via a variable instead (e.g. set the question field to {{ $json.chatInput }}). |
Example A: parameterised system prompt, free-form user input:
Langfuse prompt:
system: "You help customers of {{company}}."Node config:
Prompt Variables: company = Acme
Prompt Type: Auto
Result:
system → "You help customers of Acme."
human → chatInput from previous node (unchanged)
Example B: fully parameterised prompt:
Langfuse prompt:
system: "You are a support agent."
user: "Ticket {{ticket_id}}: {{question}}"Node config:
Prompt Variables:
ticket_id = {{ $json.ticketId }}
question = {{ $json.message }}
Result (chatInput ignored):
system → "You are a support agent."
human → "Ticket 4821: Where is my order?"
Prompt Type (User Input)
| Option | Description |
|——–|————-|
| Auto (From Previous Node) | Reads the chatInput field from the previous node’s output. Works automatically with Chat Trigger and other AI nodes. |
| Define Below | Write a fixed prompt text in the node. |
> Ignored when the selected Langfuse prompt defines a user-role message. See Prompt Variables above.
Langfuse Metadata
| Field | Description |
|——-|————-|
| Session ID | Groups related traces in Langfuse. Supports n8n expressions (e.g., {{ $json.sessionId }}). |
| User ID | Identifies the end user. Supports expressions. |
| Environment | The Langfuse environment for the trace, e.g. production or staging. Left empty, Langfuse applies its own default. |
| Trace Name | Custom name for the trace. Defaults to . For example, a node named “AI Agent – Selector” in the workflow “Customer Support” produces the trace name “Customer Support – AI Agent – Selector”. |
| Custom Metadata (JSON) | Any additional metadata you want to attach to traces. |
#### Automatic Metadata
The following fields are automatically included in every trace, with no configuration needed:
| Field | Value | Source |
|——-|——-|——–|
| execution_id | The n8n execution ID | n8n |
| workflow.id | The n8n workflow ID | n8n |
| workflow.name | The n8n workflow name | n8n |
| workflow.active | Whether the workflow is active | n8n |
| node | The node name | n8n |
| project | Your Langfuse project name | Langfuse API |
| prompt.name | The selected prompt name | Langfuse prompt |
| prompt.version | The production version number | Langfuse prompt |
> Reserved keys: execution_id, workflow, node, project, and prompt are reserved for the auto-populated values above. These fields are factual and always win: if your Custom Metadata JSON includes any of them, those keys are dropped and a warning listing the ignored keys is written to the n8n log.
Example Custom Metadata:
{
"env": "prod",
"tenant": "{{ $json.tenantId }}"
}
Resulting trace metadata:
{
"execution_id": "1234",
"workflow": { "id": "aB3dE5fG", "name": "Customer Support Agent", "active": true },
"node": "AI Agent - Selector",
"project": "my-project",
"prompt": { "name": "my-agent", "version": 3 },
"env": "prod",
"tenant": "acme-corp"
}
The Trace in Langfuse
Every execution produces a full trace in Langfuse showing:
Node Output
Each output item carries the agent answer in output, plus the trace’s identity, so a downstream node can link to it, attach a score, or gate on it:
| Field | Value |
|——-|——-|
| langfuseTrace.id | The trace id (matches the trace in Langfuse). |
| langfuseTrace.url | A direct link to the trace, e.g. https://cloud.langfuse.com/project/. Present when the project id can be read from the Langfuse API. |
#### Parse Output as JSON
When the prompt makes the agent answer with a JSON object, the Parse Output as JSON toggle (off by default) parses that answer and returns its fields as the item, so no downstream Code or Set node is needed to unwrap it:
// Toggle off (default)
{ "output": "{"sentiment": "positive", "score": 0.9}", "langfuseTrace": { "id": "...", "url": "..." } }// Toggle on
{ "sentiment": "positive", "score": 0.9, "langfuseTrace": { "id": "...", "url": "..." } }
Code fences and surrounding text are cleaned before parsing. If the answer still is not a JSON object, the node fails, or emits an { "error": ..., "langfuseTrace": ... } item when Continue On Fail is set. langfuseTrace and intermediateSteps are reserved keys: they always win over same-named fields in the parsed answer. The toggle is hidden when an output parser is connected, and the parser wins.
Options
| Option | Default | Description |
|——–|———|————-|
| System Message | “You are a helpful assistant” | System prompt (only when Prompt Source = Manual) |
| Max Iterations | 10 | Maximum agent reasoning loops |
| Return Intermediate Steps | false | Include tool calls and reasoning in output |
| Enable Streaming | true | Stream responses in real-time |
| Automatically Passthrough Binary Images | true | Forward input images to the model as image messages |
| Automatically Passthrough Binary PDFs | false | Forward input PDFs to models that read them natively (e.g. Google Gemini). Text files (JSON, XML, CSV, YAML) ride along whenever either passthrough option is on. Attachments over 50 MB are refused |
| Batch Size | 1 | Items to process in parallel |
| Delay Between Batches | 0 ms | Wait time between batches |
Canvas Inputs
| Input | Type | Required | Description |
|——-|——|———-|————-|
| Chat Model | Language Model | Yes | Any LangChain-compatible model (OpenAI, OpenRouter, Anthropic, etc.). Provides the LLM provider and API key. |
| Tools | Tool | No | Connect one or more tools for the agent to use. |
| Memory | Memory | No | Conversation memory for multi-turn agents. |
| Output Parser | Output Parser | No | Structured output format (enable “Require Specific Output Format” first). |
| Fallback Model | Language Model | No | Backup model (enable “Enable Fallback Model” first). |
Examples
Basic: Agent with Langfuse Prompt
1. Set Prompt Source = “Langfuse Prompt”
2. Select your prompt from the dropdown
3. Set Model Source = “From Langfuse”
4. Set Prompt Type = “Define Below” and enter a test message
Sub-workflow: Reusable Agent
Perfect for n8n pipelines where multiple workflows call the same agent. Each gets its own Langfuse trace with the correct prompt and model.
With Tools and Memory
!Chat example with tools and memory
Full conversational agent with tool access and conversation history, all traced to Langfuse.
Multiple Langfuse Projects
Each Langfuse API key pair belongs to one project. To use prompts from different projects:
1. Create a separate Agent Langfuse API credential for each project
2. Select the appropriate credential in each node
3. The project name in trace metadata updates automatically
Compatibility
| Component | Version |
|———–|———|
| n8n | >= 2.0.0 |
| Node.js | >= 20.15 |
| Langfuse | >= 3.0 |
On n8n 1.x, use 0.3.3. Langfuse 3.0 is the floor because traces are sent through
its OpenTelemetry endpoint, which earlier servers do not expose. Verified against
a self-hosted Langfuse 3.205.
Works with any LangChain-compatible Chat Model: OpenAI, OpenRouter, Anthropic, Azure OpenAI, Google Vertex AI, Ollama, and more.
Decision Agent + Langfuse does not take a Chat Model. It needs n8n’s OpenRouter credential and a
decision model served there, and it calls /api/alpha/decisions, which is an alpha endpoint: pin the
model version rather than a moving alias.
Upgrading
Full release-by-release detail lives in the CHANGELOG. The changes that need action:
AI Agent + Langfuse untouched: same name, same credential, same parameters. The new node appears in the palette and is ignored until you use it.langfuseTraceId / langfuseTraceUrl fields to the nested langfuseTrace: { id, url }. If a downstream node read the flat fields, point it at the nested ones.@langchain/core 1.x, the major n8n 2.x runs; this is also what makes tool calling work) and a Langfuse server on 3.x (traces go through its OpenTelemetry endpoint). On n8n 1.x, stay on 0.3.3. No credential change.langfuseApi to agentLangfuseApi (Agent Langfuse API) to stop colliding with other Langfuse packages. There is no automatic migration: create a new credential with the same values and select it in each node. The old credential is not deleted; it simply no longer matches this node.Troubleshooting
“Cannot connect to Langfuse”
401 “Invalid credentials. Confirm that you’ve configured the correct host.” (self-hosted)
That error body comes from Langfuse Cloud, so on a self-hosted instance it means requests are reaching cloud.langfuse.com instead of your Base URL. Check that the credential’s Base URL points at your instance and that n8n can reach it from inside its container. On 0.2.x this was caused by a credential type name collision with the official Langfuse package; upgrade to 0.3.0 or later and recreate the credential (see Upgrading).
Prompt dropdown is empty
chat-type prompts (not text-type)Model from Langfuse not being used
model field in your Langfuse prompt config must match your provider’s model naming (e.g., openai/gpt-5-nano for OpenRouter, gpt-4o for OpenAI direct)“Failed to receive response” with Chat Trigger
Development
git clone https://github.com/Diward/n8n-nodes-agent-langfuse.git
cd n8n-nodes-agent-langfuse
npm install
npm run buildInstall locally in n8n for testing
cd ~/.n8n/nodes
npm install /path/to/n8n-nodes-agent-langfuse
Restart n8n
Contributing
Contributions are welcome! Please open an issue first to discuss what you’d like to change.