Marcelo Trylesinski
22 lines
651 B
Python
22 lines
651 B
Python
from mcp.server.mcpserver import Context, MCPServer
|
|
from mcp.server.session import ServerSession
|
|
|
|
mcp = MCPServer(name="Progress Example")
|
|
|
|
|
|
@mcp.tool()
|
|
async def long_running_task(task_name: str, ctx: Context[ServerSession, None], steps: int = 5) -> str:
|
|
"""Execute a task with progress updates."""
|
|
await ctx.info(f"Starting: {task_name}")
|
|
|
|
for i in range(steps):
|
|
progress = (i + 1) / steps
|
|
await ctx.report_progress(
|
|
progress=progress,
|
|
total=1.0,
|
|
message=f"Step {i + 1}/{steps}",
|
|
)
|
|
await ctx.debug(f"Completed step {i + 1}")
|
|
|
|
return f"Task '{task_name}' completed"
|