Skip to content

Commit b94ae31

Browse files
fix: send err when validation error
1 parent 7e6f6b5 commit b94ae31

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/mcpm/router/transport.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ async def handle_post_message(self, scope: Scope, receive: Receive, send: Send):
220220
response = Response("Could not parse message", status_code=400)
221221
await response(scope, receive, send)
222222
try:
223-
await writer.send(SessionMessage(message=err))
223+
await writer.send(err)
224224
except (BrokenPipeError, ConnectionError, OSError) as pipe_err:
225225
logger.warning(f"Failed to send error due to pipe issue: {pipe_err}")
226226
return
@@ -240,7 +240,7 @@ async def handle_post_message(self, scope: Scope, receive: Receive, send: Send):
240240
logger.warning(f"Connection error when sending message to session {session_id}: {e}")
241241
self._read_stream_writers.pop(session_id, None)
242242
self._session_id_to_identifier.pop(session_id, None)
243-
243+
244244
# Implicitly return None. The original 'return response' is removed.
245245
return
246246

0 commit comments

Comments
 (0)