@@ -272,15 +272,15 @@ async def _handle_post_request(self, ctx: RequestContext) -> None:
272272 # Read body for error detail
273273 await response .aread ()
274274 body_text = response .text [:200 ] if response .text else ""
275- error_msg = f"HTTP { response .status_code } : { body_text } " if body_text else f"HTTP { response .status_code } "
275+ error_msg = (
276+ f"HTTP { response .status_code } : { body_text } " if body_text else f"HTTP { response .status_code } "
277+ )
276278 if isinstance (message , JSONRPCRequest ):
277279 error_data = ErrorData (
278280 code = INTERNAL_ERROR ,
279281 message = error_msg ,
280282 )
281- session_message = SessionMessage (
282- JSONRPCError (jsonrpc = "2.0" , id = message .id , error = error_data )
283- )
283+ session_message = SessionMessage (JSONRPCError (jsonrpc = "2.0" , id = message .id , error = error_data ))
284284 await ctx .read_stream_writer .send (session_message )
285285 return
286286
@@ -307,9 +307,7 @@ async def _handle_post_request(self, ctx: RequestContext) -> None:
307307 # so they don't hang waiting for a response that will never arrive.
308308 if isinstance (message , JSONRPCRequest ):
309309 error_data = ErrorData (code = INTERNAL_ERROR , message = str (exc ))
310- session_message = SessionMessage (
311- JSONRPCError (jsonrpc = "2.0" , id = message .id , error = error_data )
312- )
310+ session_message = SessionMessage (JSONRPCError (jsonrpc = "2.0" , id = message .id , error = error_data ))
313311 with contextlib .suppress (Exception ):
314312 await ctx .read_stream_writer .send (session_message )
315313 raise
0 commit comments