π Events: Using __event_emitter__ and __event_call__ in Open WebUI
Open WebUI's plugin architecture is not just about processing input and producing outputβit's about real-time, interactive communication with the UI and users. To make your Tools, Functions, and Pipes more dynamic, Open WebUI provides a built-in event system via the __event_emitter__ and __event_call__ helpers.
This guide explains what events are, how you can trigger them from your code, and the full catalog of event types you can use (including much more than just "input").
π What Are Events?β
Events are real-time notifications or interactive requests sent from your backend code (Tool, or Function) to the web UI. They allow you to update the chat, display notifications, request confirmation, run UI flows, and more.
- Events are sent using the
__event_emitter__helper for one-way updates, or__event_call__when you need user input or a response (e.g., confirmation, input, etc.).
Metaphor: Think of Events like push notifications and modal dialogs that your plugin can trigger, making the chat experience richer and more interactive.
π Availabilityβ
Native Python Tools & Functionsβ
Events are fully available for native Python Tools and Functions defined directly in Open WebUI using the __event_emitter__ and __event_call__ helpers.
External Tools (OpenAPI & MCP)β
External tools can emit events via a dedicated REST endpoint. Open WebUI passes the following headers to all external tool requests when ENABLE_FORWARD_USER_INFO_HEADERS=True is set:
| Header | Description |
|---|---|
X-Open-WebUI-Chat-Id | The chat ID where the tool was invoked |
X-Open-WebUI-Message-Id | The message ID associated with the tool call |
Your external tool can use these headers to emit events back to the UI via:
POST /api/v1/chats/{chat_id}/messages/{message_id}/event
See External Tool Events below for details.
π§° Basic Usageβ
Sending an Eventβ
You can trigger an event anywhere inside your Tool, or Function by calling:
await __event_emitter__(
{
"type": "status", # See the event types list below
"data": {
"description": "Processing started!",
"done": False,
"hidden": False,
},
}
)
You do not need to manually add fields like chat_id or message_idβthese are handled automatically by Open WebUI.
Interactive Eventsβ
When you need to pause execution until the user responds (e.g., confirm/cancel dialogs, code execution, or input), use __event_call__:
result = await __event_call__(
{
"type": "input", # Or "confirmation", "execute"
"data": {
"title": "Please enter your password",
"message": "Password is required for this action",
"placeholder": "Your password here",
},
}
)
# result will contain the user's input value
π Event Payload Structureβ
When you emit or call an event, the basic structure is:
{
"type": "event_type", // See full list below
"data": { ... } // Event-specific payload
}
Most of the time, you only set "type" and "data". Open WebUI fills in the routing automatically.
π Full List of Event Typesβ
Below is a comprehensive table of all supported type values for events, along with their intended effect and data structure. (This is based on up-to-date analysis of Open WebUI event handling logic.)
| type | When to use | Data payload structure (examples) |
|---|---|---|
status | Show a status update/history for a message | {description: ..., done: bool, hidden: bool} |
chat:completion | Provide a chat completion result | (Custom, see Open WebUI internals) |
chat:message:delta,message | Append content to the current message | {content: "text to append"} |
chat:message,replace | Replace current message content completely | {content: "replacement text"} |
chat:message:files,files | Set or overwrite message files (for uploads, output) | {files: [...]} |
chat:title | Set (or update) the chat conversation title | Topic string OR {title: ...} |
chat:tags | Update the set of tags for a chat | Tag array or object |
source,citation | Add a source/citation, or code execution result | For code: See below. |
notification | Show a notification ("toast") in the UI | {type: "info" or "success" or "error" or "warning", content: "..."} |
confirmation (needs __event_call__) | Ask for confirmation (OK/Cancel dialog) | {title: "...", message: "..."} |
input (needs __event_call__) | Request simple user input ("input box" dialog) | {title: "...", message: "...", placeholder: "...", value: ..., type: "password"} (type is optional) |
execute (needs __event_call__) | Request user-side code execution and return result | {code: "...javascript code..."} |
chat:message:favorite | Update the favorite/pin status of a message | {"favorite": bool} |
Other/Advanced types:
- You can define your own types and handle them at the UI layer (or use upcoming event-extension mechanisms).
β Details on Specific Event Typesβ
statusβ
Show a status/progress update in the UI:
await __event_emitter__(
{
"type": "status",
"data": {
"description": "Step 1/3: Fetching data...",
"done": False,
"hidden": False,
},
}
)
chat:message:delta or messageβ
Streaming output (append text):
await __event_emitter__(
{
"type": "chat:message:delta", # or simply "message"
"data": {
"content": "Partial text, "
},
}
)
# Later, as you generate more:
await __event_emitter__(
{
"type": "chat:message:delta",
"data": {
"content": "next chunk of response."
},
}
)
chat:message or replaceβ
Set (or replace) the entire message content:
await __event_emitter__(
{
"type": "chat:message", # or "replace"
"data": {
"content": "Final, complete response."
},
}
)
files or chat:message:filesβ
Attach or update files:
await __event_emitter__(
{
"type": "files", # or "chat:message:files"
"data": {
"files": [
# Open WebUI File Objects
]
},
}
)
chat:titleβ
Update the chat's title:
await __event_emitter__(
{
"type": "chat:title",
"data": {
"title": "Market Analysis Bot Session"
},
}
)
chat:tagsβ
Update the chat's tags:
await __event_emitter__(
{
"type": "chat:tags",
"data": {
"tags": ["finance", "AI", "daily-report"]
},
}
)
source or citation (and code execution)β
Add a reference/citation:
await __event_emitter__(
{
"type": "source", # or "citation"
"data": {
# Open WebUI Source (Citation) Object
}
}
)
For code execution (track execution state):
await __event_emitter__(
{
"type": "source",
"data": {
# Open WebUI Code Source (Citation) Object
}
}
)
notificationβ
Show a toast notification:
await __event_emitter__(
{
"type": "notification",
"data": {
"type": "info", # "success", "warning", "error"
"content": "The operation completed successfully!"
}
}
)
chat:message:favoriteβ
Update the favorite/pin status of a message:
await __event_emitter__(
{
"type": "chat:message:favorite",
"data": {
"favorite": True # or False to unpin
}
}
)
What this does exactly:
This event forces the Open WebUI frontend to update the "favorite" state of a message in its local cache. Without this emitter, if an Action Function modifies the message.favorite field in the database directly, the frontend (which maintains its own state) might overwrite your change during its next auto-save cycle. This emitter ensures the UI and database stay perfectly in sync.
Where it appears:
- Message Toolbar: When set to
True, the "Heart" icon beneath the message will fill in, indicating it is favorited. - Chat Overview: Favorited messages (pins) are highlighted in the conversation overview, making it easier for users to locate key information later.
Example: "Pin Message" Actionβ
For a practical implementation of this event in a real-world plugin, see the Pin Message Action on Open WebUI Community. This action demonstrates how to toggle the favorite status in the database and immediately sync the UI using the chat:message:favorite event.
confirmation (requires __event_call__)β
Show a confirm dialog and get user response:
result = await __event_call__(
{
"type": "confirmation",
"data": {
"title": "Are you sure?",
"message": "Do you really want to proceed?"
}
}
)
if result: # or check result contents
await __event_emitter__({
"type": "notification",
"data": {"type": "success", "content": "User confirmed operation."}
})
else:
await __event_emitter__({
"type": "notification",
"data": {"type": "warning", "content": "User cancelled."}
})
input (requires __event_call__)β
Prompt user for text input:
result = await __event_call__(
{
"type": "input",
"data": {
"title": "Enter your name",
"message": "We need your name to proceed.",
"placeholder": "Your full name"
}
}
)
user_input = result
await __event_emitter__(
{
"type": "notification",
"data": {"type": "info", "content": f"You entered: {user_input}"}
}
)
Masked / Password Inputβ
To hide sensitive input (e.g., API keys, passwords), set type to "password" in the data payload. The input field will be rendered as a masked password input with a show/hide toggle:
result = await __event_call__(
{
"type": "input",
"data": {
"title": "Enter API Key",
"message": "Your API key is required for this integration.",
"placeholder": "sk-...",
"type": "password"
}
}
)
This uses the same SensitiveInput component used for user valve password fields, providing a familiar "eye" icon toggle for showing/hiding the value.
execute (requires __event_call__)β
Run JavaScript directly in the user's browser:
result = await __event_call__(
{
"type": "execute",
"data": {
"code": "return document.title;",
}
}
)
await __event_emitter__(
{
"type": "notification",
"data": {
"type": "info",
"content": f"Page title: {result}"
}
}
)
How It Worksβ
The execute event runs JavaScript directly in the main page context using new Function(). This means:
- It runs with full access to the page's DOM, cookies, localStorage, and session
- It is not sandboxed β there are no iframe restrictions
- It can manipulate the Open WebUI interface directly (show/hide elements, read form data, trigger downloads)
- The code runs as an async function, so you can use
awaitandreturna value back to the backend
Because execute runs in the main page context with full DOM access, you can use it to automate virtually anything on the Open WebUI frontend: click buttons, fill input fields, navigate between pages, read page state, trigger downloads, interact with the model selector, submit messages on behalf of the user, and more. Think of it as a remote control for the browser UI β if a user can do it manually, your function can do it programmatically via execute.
Example: Display a Custom Formβ
result = await __event_call__(
{
"type": "execute",
"data": {
"code": """
return new Promise((resolve) => {
const overlay = document.createElement('div');
overlay.style.cssText = 'position:fixed;inset:0;background:rgba(0,0,0,0.5);display:flex;align-items:center;justify-content:center;z-index:9999';
overlay.innerHTML = `
<div style="background:white;padding:24px;border-radius:12px;min-width:300px">
<h3 style="margin:0 0 12px">Enter Details</h3>
<input id="exec-name" placeholder="Name" style="width:100%;padding:8px;margin:4px 0;border:1px solid #ccc;border-radius:6px"/>
<input id="exec-email" placeholder="Email" style="width:100%;padding:8px;margin:4px 0;border:1px solid #ccc;border-radius:6px"/>
<button id="exec-submit" style="margin-top:12px;padding:8px 16px;background:#333;color:white;border:none;border-radius:6px;cursor:pointer">Submit</button>
</div>
`;
document.body.appendChild(overlay);
document.getElementById('exec-submit').onclick = () => {
const name = document.getElementById('exec-name').value;
const email = document.getElementById('exec-email').value;
overlay.remove();
resolve({ name, email });
};
});
"""
}
}
)
# result will be {"name": "...", "email": "..."}
Execute vs Rich UI Embedsβ
The execute event and Rich UI Embeds are complementary ways to create interactive experiences:
execute Event | Rich UI Embed | |
|---|---|---|
| Runs in | Main page context (no sandbox) | Sandboxed iframe |
| Persistence | Ephemeral β gone on reload/navigate | Persistent β saved in chat history |
| Page access | Full (DOM, cookies, localStorage) | Isolated from parent by default |
| Forms | Always works (no sandbox) | Requires allowForms setting enabled |
| Best for | Transient interactions, side effects, downloads, DOM manipulation | Persistent visual content, dashboards, charts |
Use execute for transient interactions (confirmations, custom dialogs, triggering downloads, reading page state) and Rich UI embeds for persistent visual content you want to stay in the conversation.
Because execute runs unsandboxed JavaScript in the user's browser session, it has full access to the Open WebUI page context. Only use this in trusted functions β never execute untrusted or user-provided code through this event.
ποΈ When & Where to Use Eventsβ
- From any Tool, or Function in Open WebUI.
- To stream responses, show progress, request user data, update the UI, or display supplementary info/files.
await __event_emitter__is for one-way messages (fire and forget).await __event_call__is for when you need a response from the user (input, execute, confirmation).
π‘ Tips & Advanced Notesβ
- Multiple types per message: You can emit several events of different types for one messageβfor example, show
statusupdates, then stream withchat:message:delta, then complete with achat:message. - Custom event types: While the above list is the standard, you may use your own types and detect/handle them in custom UI code.
- Extensibility: The event system is designed to evolveβalways check the Open WebUI documentation for the most current list and advanced usage.
π§ FAQβ
Q: How do I trigger a notification for the user?β
Use notification type:
await __event_emitter__({
"type": "notification",
"data": {"type": "success", "content": "Task complete"}
})
Q: How do I prompt the user for input and get their answer?β
Use:
response = await __event_call__({
"type": "input",
"data": {
"title": "What's your name?",
"message": "Please enter your preferred name:",
"placeholder": "Name"
}
})
# response will be: {"value": "user's answer"}
Q: What event types are available for __event_call__?β
"input": Input box dialog"confirmation": Yes/No, OK/Cancel dialog"execute": Run provided code on client and return result
Q: Can I update files attached to a message?β
Yesβuse the "files" or "chat:message:files" event type with a {files: [...]} payload.
Q: Can I update the conversation title or tags?β
Absolutely: use "chat:title" or "chat:tags" accordingly.
Q: Can I stream responses (partial tokens) to the user?β
Yesβemit "chat:message:delta" events in a loop, then finish with "chat:message".
π External Tool Eventsβ
External tools (OpenAPI and MCP servers) can emit events to the Open WebUI UI via a REST endpoint. This enables features like status updates, notifications, and streaming content from tools running on external servers.
Prerequisitesβ
To receive the chat and message ID headers, you must enable header forwarding by setting the following environment variable on your Open WebUI instance:
ENABLE_FORWARD_USER_INFO_HEADERS=True
Without this, Open WebUI will not include the identification headers in requests to external tools, and event emitting will not work.
Headers Provided by Open WebUIβ
When Open WebUI calls your external tool (with header forwarding enabled), it includes these headers:
| Header | Description | Env Var Override |
|---|---|---|
X-Open-WebUI-Chat-Id | The chat ID where the tool was invoked | FORWARD_SESSION_INFO_HEADER_CHAT_ID |
X-Open-WebUI-Message-Id | The message ID associated with the tool call | FORWARD_SESSION_INFO_HEADER_MESSAGE_ID |
Event Endpointβ
Endpoint: POST /api/v1/chats/{chat_id}/messages/{message_id}/event
Authentication: Requires a valid Open WebUI API key or session token.
Request Body:
{
"type": "status",
"data": {
"description": "Processing your request...",
"done": false
}
}
Supported Event Typesβ
External tools can emit the same event types as native tools:
statusβ Show progress/status updatesnotificationβ Display toast notificationschat:message:delta/messageβ Append content to the messagechat:message/replaceβ Replace message contentfiles/chat:message:filesβ Attach filessource/citationβ Add citations
Interactive events (input, confirmation, execute) require __event_call__ and are not supported for external tools as they need bidirectional WebSocket communication.
Example: Python External Toolβ
import httpx
def my_tool_handler(request):
# Extract headers from incoming request
chat_id = request.headers.get("X-Open-WebUI-Chat-Id")
message_id = request.headers.get("X-Open-WebUI-Message-Id")
api_key = "your-open-webui-api-key"
# Emit a status event
httpx.post(
f"http://your-open-webui-host/api/v1/chats/{chat_id}/messages/{message_id}/event",
headers={"Authorization": f"Bearer {api_key}"},
json={
"type": "status",
"data": {"description": "Working on it...", "done": False}
}
)
# ... do work ...
# Emit completion status
httpx.post(
f"http://your-open-webui-host/api/v1/chats/{chat_id}/messages/{message_id}/event",
headers={"Authorization": f"Bearer {api_key}"},
json={
"type": "status",
"data": {"description": "Complete!", "done": True}
}
)
return {"result": "success"}
Example: JavaScript/Node.js External Toolβ
async function myToolHandler(req) {
const chatId = req.headers['x-open-webui-chat-id'];
const messageId = req.headers['x-open-webui-message-id'];
const apiKey = 'your-open-webui-api-key';
// Emit a notification
await fetch(
`http://your-open-webui-host/api/v1/chats/${chatId}/messages/${messageId}/event`,
{
method: 'POST',
headers: {
'Authorization': `Bearer ${apiKey}`,
'Content-Type': 'application/json'
},
body: JSON.stringify({
type: 'notification',
data: { type: 'info', content: 'Tool is processing...' }
})
}
);
return { result: 'success' };
}
π Persistence & Browser Disconnectionβ
A common question is: what happens if the browser tab is closed while a tool, action, or pipe is still running?
Server-Side Execution Continuesβ
When you send a chat request, Open WebUI creates a background asyncio task that is not tied to your HTTP connection or Socket.IO session. If you close the tab:
- The WebSocket disconnects and the Socket.IO disconnect handler fires
- The disconnect handler cleans up session data but does not cancel any running tasks
- The background task continues running to completion on the server
sio.emit()calls succeed silently β events are sent to an empty room and discarded- Database writes still happen for persisted event types (see below)
- The task runs until the function returns, raises an error, or is manually cancelled
There is no timeout on pipe, tool, or action execution. Your code can run for minutes or hours β nothing in Open WebUI will kill it automatically. The only things that can stop a running task are:
- The function itself returning or raising an exception
- Manual cancellation via
POST /api/tasks/stop/{task_id}(the stop button in the UI) - The Open WebUI server process restarting
Which Event Types Are Persisted to the Database?β
The event emitter writes certain event types directly to the database regardless of whether a browser is connected. These writes are independent of the ENABLE_REALTIME_CHAT_SAVE setting.
β Persisted (survive tab close)β
| Type | What's saved |
|---|---|
status | Appended to the message's statusHistory array |
message | Appended to the message's content field |
replace | Overwrites the message's content field |
embeds | Appended to the message's embeds array (Rich UI HTML) |
files | Appended to the message's files array |
source / citation | Appended to the message's sources array |
These 6 types always write to the database inside the event emitter function itself, completely independent of ENABLE_REALTIME_CHAT_SAVE.
The backend event emitter only recognizes the short names above for DB writes. If you emit "chat:message:embeds" instead of "embeds", the frontend handles it identically, but the backend won't persist it. Always use the short names ("status", "message", "replace", "embeds", "files", "source") if you need persistence.
β Not persisted (lost on tab close)β
| Type | Why it's lost |
|---|---|
chat:completion | Streaming LLM deltas β Socket.IO only |
chat:message:delta | Frontend alias, backend doesn't persist |
chat:message | Frontend alias, backend doesn't persist |
chat:message:files | Frontend alias, backend doesn't persist |
chat:message:embeds | Frontend alias, backend doesn't persist |
chat:message:error | Socket.IO only |
chat:message:follow_ups | Socket.IO only |
chat:message:favorite | Socket.IO only (updates frontend state) |
chat:title | Socket.IO only |
chat:tags | Socket.IO only |
notification | Toast popup β Socket.IO only |
If your pipe or tool needs to call an LLM and have the result persist even when the browser is closed, you can import and use generate_chat_completion from Open WebUI's internals instead of emitting chat:completion events. The completion flows through the normal chat pipeline and its result is saved to the database like any other assistant message.
β οΈ Requires live connection (will error on tab close)β
| Type | Why |
|---|---|
confirmation | Uses sio.call() β waits for client response, will timeout |
input | Uses sio.call() β waits for client response, will timeout |
execute | Uses sio.call() β waits for client response, will timeout |
These __event_call__ types fundamentally require a live browser connection. If the tab is closed, sio.call() will timeout and raise an exception in your function code.
Return Value Persistenceβ
The final return value of your function is always saved to the database when the task completes, regardless of browser state.
Pipesβ
When a pipe's pipe() method returns (or its generator finishes yielding), the streaming handler saves the final result at completion:
- If
ENABLE_REALTIME_CHAT_SAVEis on: intermediate chunks are saved during streaming - If
ENABLE_REALTIME_CHAT_SAVEis off: the full final content is saved in one write at completion
Either way, the final assistant message is always persisted. When you reopen the chat, it will be there.
Toolsβ
| Return type | What happens | Persisted? |
|---|---|---|
HTMLResponse (with Content-Disposition: inline) | HTML body extracted β added to embeds β emitted as "embeds" event | β Yes |
HTMLResponse (without inline) | Body decoded as plain text tool result | β Yes |
str / dict | Used as tool result text | β Yes |
list (MCP) | Text items joined, images converted to files | β Yes |
Actionsβ
Actions go through the same return handling as tools. The same persistence rules apply:
| Return type | What happens | Persisted? |
|---|---|---|
HTMLResponse (with Content-Disposition: inline) | HTML body extracted β added to embeds β emitted as "embeds" event | β Yes |
HTMLResponse (without inline) | Body decoded as plain text result | β Yes |
str / dict | Used as action result text | β Yes |
Filtersβ
Filters transform form_data in the pipeline β they don't return results to the user directly. However, filters do receive __event_emitter__ and can emit persisted event types like "status", "embeds", "message", etc.
Function Type Capabilities Matrixβ
| Capability | Tools | Actions | Pipes | Filters |
|---|---|---|---|---|
__event_emitter__ | β | β | β | β |
__event_call__ | β | β | β | β |
| Return value β user response | β | β | β | β (modifies form_data) |
HTMLResponse β Rich UI embed | β | β | β | β |
Practical Summaryβ
If you want your function's output to survive a closed browser tab, follow these rules:
- Always return your final answer from your
pipe(), tool, or action function β the return value is always saved - Use short event type names (
"status","message","embeds","files","source") for DB persistence - Avoid relying on
"notification","confirmation","input", or"execute"for critical workflows β these require a live browser connection - Rich UI HTML embeds (
"embeds"type orHTMLResponsereturn) are persisted and will render when the user reopens the chat
π Conclusionβ
Events give you real-time, interactive superpowers inside Open WebUI. They let your code update content, trigger notifications, request user input, stream results, handle code, and much moreβseamlessly plugging your backend intelligence into the chat UI.
- Use
__event_emitter__for one-way status/content updates. - Use
__event_call__for interactions that require user follow-up (input, confirmation, execution).
Refer to this document for common event types and structures, and explore Open WebUI source code or docs for breaking updates or custom events!
Happy event-driven coding in Open WebUI! π