iUddlZddlmZmZddlmZmZmZddlZ ddl m Z m Z ddl m Z ddlmZddlmZmZddlmZdd lmZmZee zezZeed <ed e eZeeeeeeefgeeezfZeed <gd Zdede fdZy)N) AwaitableCallable) TypeAliasTypeVarcast) ClientSessionCreateMessageResult) SamplingFnT) ServerSession)LifespanContextTRequestContext)CreateMessageRequestParams)CreateMessageResultWithToolsSamplingMessageSamplingHandlerResultSessionTSamplingHandler)r rrrSamplingParamscreate_sampling_callbacksampling_handlerreturncpdtdttztjj zffd }|S)NparamsrcK |j||}tj|r |d{}t|tr-t ddt jjd|}|S7C#t$rL}t jjt jjt |cYd}~Sd}~wwxYww)N assistantzfastmcp-clienttext)typer)rolemodelcontent)codemessage) messagesinspect isawaitable isinstancestrr mcptypes TextContent Exception ErrorDataINTERNAL_ERROR)contextrresulters p/Users/bowang/.openclaw/workspace/ChatDev/.venv/lib/python3.12/site-packages/fastmcp/client/sampling/__init__.py_sampling_handlerz3create_sampling_callback.._sampling_handler/s %foovwGF""6*%&#&,$*II11vF1K M& 99&&YY--A'  sFC.A9A7AA96C7A99 CAC CC CC)rr rr(r)r,)rr2s` r1rr,s7 ; ;cii>Q>Q Q, )r$collections.abcrrtypingrrr mcp.typesr(rr mcp.client.sessionr mcp.server.sessionr mcp.shared.contextr r rrrrr'r__annotations__rlistr__all__rr3r1r>s/++2*,?BC  <<y :}m < & _x!112 I&;<< > %r3