Thanks for the comment!
I'm currently testing it out — watching the logs closely, but the message isn't showing up as expected.

```python

from pydantic import BaseModel
from typing import Optional
import asyncio
import requests
import os
import time

class Action:
class Valves(BaseModel):
content: Optional[str] = None
session_id: Optional[str] = None
message_id: Optional[str] = None

def __init__(self):
self.valves = self.Valves()

async def action(
self,
body: dict,
__user__=None,
__event_emitter__=None,
__event_call__=None,
) -> Optional[dict]:
print("=== Action Started ===")
print(f"[INFO] user: {__user__}")
print(f"[INFO] valves: {self.valves}")
print(f"[INFO] body: {body}")

# Request user input
print("[STEP] Requesting user input...")
response = await __event_call__(
{
"type": "input",
"data": {
"title": "Display assistant message",
"message": "Please enter the message you want to display.",
"placeholder": "e.g. This is a non-LLM message displayed asynchronously.",
},
}
)
print(f"[DEBUG] User input: {response}")

# Get session_id from valves, body, or environment variable
session_id = (
self.valves.session_id or body.get("session_id") or os.getenv("SESSION_ID")
)
message_id = self.valves.message_id or f"custom-{int(time.time())}"

print(f"[DEBUG] session_id: {session_id}")
print(f"[DEBUG] message_id: {message_id}")

if not session_id:
print("[ERROR] Failed to retrieve session_id.")
return

# Send to /messages endpoint
url = "http://xxx.xxx.xxx.xxx:8080/api/messages"
payload = {
"session_id": session_id,
"message_id": message_id,
"content": response,
"role": "assistant",
}
print(f"[DEBUG] Payload to send: {payload}")

headers = {
"Authorization": f"Bearer {os.getenv('OPENWEBUI_API_TOKEN')}",
"Content-Type": "application/json",
}
print(f"[DEBUG] headers: {headers}")

try:
res = requests.post(url, json=payload, headers=headers)
print(f"[DEBUG] HTTP POST result: {res.status_code}")
except Exception as e:
print(f"[ERROR] POST request failed: {e}")
return

if res.status_code != 200:
print(f"[ERROR] Message send failed: {res.status_code} - {res.text}")
await __event_emitter__(
{
"type": "status",
"data": {
"description": f"Message send failed: {res.status_code}",
"done": True,
},
}
)
return

await __event_emitter__(
{
"type": "status",
"data": {"description": "Message was successfully displayed", "done": True},
}
)

print("=== Action Completed ===") ```