k7i.SrSSKrSSKrSSKrSSKJr SSKJr SSKrSSK J r SSK J r SSK Jr SS KJrJrJr "S S \5r"S S \5rg)zFError handling middleware for consistent error responses and tracking.N)Callable)Any)McpError) ErrorData) NotFoundError)CallNext MiddlewareMiddlewareContextc \rSrSrSrSS\R S-S\S\\ \ /S4S-S\4Sjjr S \ S \ S S4S jr S \ S \ 4S jr S \ S\S \4SjrS \\\44SjrSrg)ErrorHandlingMiddlewareaMiddleware that provides consistent error handling and logging. Catches exceptions, logs them appropriately, and converts them to proper MCP error responses. Also tracks error patterns for monitoring. Example: ```python from fastmcp.server.middleware.error_handling import ErrorHandlingMiddleware import logging # Configure logging to see error details logging.basicConfig(level=logging.ERROR) mcp = FastMCP("MyServer") mcp.add_middleware(ErrorHandlingMiddleware()) ``` Nloggerinclude_tracebackerror_callbacktransform_errorsc~U=(d [R"S5UlX lX0lX@l0Ulg)aMInitialize error handling middleware. Args: logger: Logger instance for error logging. If None, uses 'fastmcp.errors' include_traceback: Whether to include full traceback in error logs error_callback: Optional callback function called for each error transform_errors: Whether to transform non-MCP errors to McpError zfastmcp.errorsN)logging getLoggerrrrr error_counts)selfrrrrs b/home/james-whalen/.local/lib/python3.13/site-packages/fastmcp/server/middleware/error_handling.py__init__ ErrorHandlingMiddleware.__init__%s6C 1 12B C !2, 0errorcontextreturncH[U5RnUR=(d SnUSU3nURR US5S-URU'SUSUSU<3nUR (a4UR RUS[R"535 OUR RU5 UR(aURX5 g g ![a(nUR RSU35 S nAg S nAff=f) z(Log error with appropriate detail level.unknown:rrz Error in :  zError in error callback: N) type__name__methodrgetrrr traceback format_excr Exception)rrr error_typer& error_key base_messagecallback_errors r _log_error"ErrorHandlingMiddleware._log_error:s %[)) ,9"l!F8, '+'8'8'<'*>? ?v1B5)/LM v1A%/KL r call_nextc# U"U5IShvN $N![a)nURX15 URU5nXCeSnAff=f7f)zHandle errors for all messages.N)r*r/r<)rrr>rtransformed_errors r on_message"ErrorHandlingMiddleware.on_messagersO /"7++ ++ / OOE +!% 5 5e < # .  /s0A  A  A $AA  A c6URR5$)z$Get error statistics for monitoring.)rcopy)rs rget_error_stats'ErrorHandlingMiddleware.get_error_stats}s  %%''r)rrrrr)NFNT)r% __module__ __qualname____firstlineno____doc__rLoggerboolrr*r rr/r<r rrAdictstrintrE__static_attributes__rrr r s()-"'PT!% % !)->!?!EFM   *P P4EP$P.iIB /(9 /h /SV /(c3h(rr c\rSrSrSrSSSS\\4S4S\S \S \S \S \ \ \ S 4S\ RS-4 SjjrS\ S\4SjrS\S\4SjrS\S\S\4SjrSrg)RetryMiddlewarea1Middleware that implements automatic retry logic for failed requests. Retries requests that fail with transient errors, using exponential backoff to avoid overwhelming the server or external dependencies. Example: ```python from fastmcp.server.middleware.error_handling import RetryMiddleware # Retry up to 3 times with exponential backoff retry_middleware = RetryMiddleware( max_retries=3, retry_exceptions=(ConnectionError, TimeoutError) ) mcp = FastMCP("MyServer") mcp.add_middleware(retry_middleware) ``` g?gN@g@N max_retries base_delay max_delaybackoff_multiplierretry_exceptions.rcXlX lX0lX@lXPlU=(d [ R "S5Ulg)asInitialize retry middleware. Args: max_retries: Maximum number of retry attempts base_delay: Initial delay between retries in seconds max_delay: Maximum delay between retries in seconds backoff_multiplier: Multiplier for exponential backoff retry_exceptions: Tuple of exception types that should trigger retries logger: Logger for retry attempts z fastmcp.retryN)rVrWrXrYrZrrr)rrVrWrXrYrZrs rrRetryMiddleware.__init__s7&'$""4 0B 1 1/ B rrrc,[XR5$)z-Determine if an error should trigger a retry.)r4rZ)rrs r _should_retryRetryMiddleware._should_retrys%!6!677rattemptcdURURU--n[X R5$)z-Calculate delay for the given attempt number.)rWrYminrX)rr`delays r_calculate_delay RetryMiddleware._calculate_delays*4#:#:G#CD5..))rrr>c,# Sn[URS-5HnU"U5IShvN s $ U(aUegN![anUnX@R:XdURU5(dSnA MDUR U5nUR R SURSUS-SURS-S[U5RSU<SUS S 3 5 [R"U5IShvN SnAMSnAff=f7f) z#Implement retry logic for requests.NrzRequest z failed (attempt /z): r"z. Retrying in z.1fzs...) rangerVr*r^rdrwarningr&r$r%anyiosleep)rrr> last_errorr`rrcs r on_requestRetryMiddleware.on_requests  T--12G )&w///3&   #0 )" ...d6H6H6O6O--g6 ##w~~..?! }AdN^N^abNbMccfE{++,Bui~eC[PTV kk%((( )sTD A?ADA D 'D 2D9BD DD D DD)rYrWrrXrVrZ)r%rGrHrIrJConnectionErrorr:rOfloattupler$r*rrKrrLr^rdr r rrmrPrQrrrSrSs,$'9H,8W(,CCC C " C  Y 45 C%C48988*** (9hSVrrS)rJr;rr(collections.abcrtypingrrjmcpr mcp.typesrfastmcp.exceptionsr middlewarer r r r rSrQrrrxsFL$ ,??m(jm(`PjPr