Function _wrapped

src/mcp/shared/jsonrpc_dispatcher.py:172–176

(progress: float, total: float | None, message: str | None)

    """Wrap a user progress callback so an exception can't cancel the dispatcher's task group."""

    async def _wrapped(progress: float, total: float | None, message: str | None) -> None:
        try:
            await fn(progress, total, message)
        except Exception:
            logger.exception("progress callback raised")

    return _wrapped