Max Isbey
1b74b06753
Cut comment and docstring volume roughly in half across src, tests, examples, and docs_src: removed comments that restate the adjacent code, leftover development narration, section banners, and self-evident Args/Returns blocks, and compressed the remaining docstrings to a Google-style summary line plus only the detail that earns its place. Kept (and tightened) the load-bearing content: Raises sections, deprecation and version-availability notes, spec/RFC/issue references, why-comments for non-obvious decisions, and all coverage pragmas. The generated mcp_types.v* wire modules are untouched.
30 lines
948 B
Python
30 lines
948 B
Python
"""MCPServer Echo Server that sends log messages and progress updates to the client"""
|
|
|
|
import asyncio
|
|
|
|
from mcp.server.mcpserver import Context, MCPServer
|
|
|
|
mcp = MCPServer("Echo Server with logging and progress updates")
|
|
|
|
|
|
@mcp.tool()
|
|
async def echo(text: str, ctx: Context) -> str:
|
|
"""Echo the input text sending log messages and progress updates during processing."""
|
|
await ctx.report_progress(progress=0, total=100)
|
|
await ctx.info("Starting to process echo for input: " + text)
|
|
|
|
await asyncio.sleep(2)
|
|
|
|
await ctx.info("Halfway through processing echo for input: " + text)
|
|
await ctx.report_progress(progress=50, total=100)
|
|
|
|
await asyncio.sleep(2)
|
|
|
|
await ctx.info("Finished processing echo for input: " + text)
|
|
await ctx.report_progress(progress=100, total=100)
|
|
|
|
# Clients process progress notifications asynchronously; a short delay lets the last one arrive.
|
|
await asyncio.sleep(0.1)
|
|
|
|
return text
|