k7iSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r SSK J r JrJrJrJrJr SSKrSSKrSSKrSSKJrJr SSKJrJrJrJrJr SSKJ r SSK!J"r" SS K#J$r$ SS K%J&r' SS K(J)r) SS K*J+r+ SS K,J-r- SSK.J/r/J0r0 SSK1r1SSK2J3r3 SSK4J5r5 SSK6J7r7J8r8 SSK9J:r: SS K;J&r& SSKJ?r? \="\@5rA\"SSS9rB/SQrC"SS\/SS9rD"SS\R5rF"SS\F5rG"S S!\F5rH"S"S#\F5rI"S$S%\F5rJS&\KS'\L\KS(\M\K\K4S-S)\KS-S*\ \-S-S+\DS,\RS-\RS.\R\4S/jrP"S0S1\J5rQ"S2S3\J5rR"S4S5\J5rS"S6S7\J5rT"S8S9\J5rU"S:S;\J5rV"S<S=\F5rW\RS>\&\'-S?\ S4S@j5rY"SASB\F5rZ\SC\BS?\B4SDj5r[\SC\&S?\W4SEj5r[\SC\'S?\W4SFj5r[\SC\7S?\Z4SGj5r[\SC\M\K\ 4S?\Z4SHj5r[\SC\-S?\H\I-4SIj5r[\SC\KS?\Q\S-\H-\I-4SJj5r[\SC\ S?\Q\S-4SKj5r[SC\F\&-\'-\--\ -\7-\M\K\ 4-\K-S?\F4SLjr[g)MN) AsyncIterator)Path)AnyLiteralTextIOTypeVarcastoverload) ClientSessionStdioServerParameters)ElicitationFnT ListRootsFnT LoggingFnTMessageHandlerFnT SamplingFnT) sse_client) stdio_client)streamablehttp_client)FastMCP)McpHttpClientFactory)#create_client_server_memory_streams)AnyUrl) TypedDictUnpack) BearerAuth)OAuth) MCPConfiginfer_transport_type_from_url)get_http_headers) get_logger) UVEnvironmentClientTransportTClientTransport)bound) r#FastMCPStdioTransportFastMCPTransportNodeStdioTransportNpxStdioTransportPythonStdioTransport SSETransportStdioTransportStreamableHttpTransportUvStdioTransportUvxStdioTransportinfer_transportc\rSrSr%Sr\R S-\S'\S-\S'\ S-\S'\ S-\S'\ S-\S'\ S-\S '\ RRS-\S 'S rg) SessionKwargs?z8Keyword arguments for the MCP ClientSession constructor.Nread_timeout_secondssampling_callbacklist_roots_callbacklogging_callbackelicitation_callbackmessage_handler client_info)__name__ __module__ __qualname____firstlineno____doc__datetime timedelta__annotations__rrrr rmcptypesImplementation__static_attributes__r:S/home/james-whalen/.local/lib/python3.13/site-packages/fastmcp/client/transports.pyr1r1?sbB",,t33"T))%,, 4''(4//&--))D00rGr1F)totalc\rSrSrSr\R \RS\ \ S\ \ 4Sj55r S\4SjrSrS\R$\S -\-S -4S jrS rg ) r#Kz Abstract base class for different MCP client transport mechanisms. A Transport is responsible for establishing and managing connections to an MCP server, and providing a ClientSession within an async context. session_kwargsreturnc # [e7f)a Establishes a connection and yields an active ClientSession. The ClientSession is *not* expected to be initialized in this context manager. The session is guaranteed to be valid only within the scope of the async context manager. Connection setup and teardown are handled within this context. Args: **session_kwargs: Keyword arguments to pass to the ClientSession constructor (e.g., callbacks, timeouts). Yields: A mcp.ClientSession instance. )NotImplementedErrorselfrLs rHconnect_sessionClientTransport.connect_sessionTs *"!s c6SURRS3$)N<>) __class__r;rQs rH__repr__ClientTransport.__repr__ls4>>**+1--rGc # g7f)zClose the transport.Nr:rXs rHcloseClientTransport.closepssauthoauthNc Ub [S5eg)Nz$This transport does not support auth) ValueErrorrQr^s rH _set_authClientTransport._set_authss  CD D rGr:)r;r<r=r>r?abcabstractmethod contextlibasynccontextmanagerrr1rr rRstrrYr\httpxAuthrrcrFr:rGrHr#r#Ks ## &} 5 } %$,.#.#Eejj77+;;cADHErGcv\rSrSrSrS\\-4Sjr\RS\ \ S\ \ 4Sj5rS\4SjrS rg ) WSTransportxzGTransport implementation that connects to an MCP server via WebSockets.urlc.[RR(a[R"S[ SS9 [ U[5(a [U5n[ U[5(aURS5(d [S5eXl g)NzwWSTransport is a deprecated MCP transport and will be removed in a future version. Use StreamableHttpTransport instead.) stacklevelwszInvalid WebSocket URL provided.) fastmcpsettingsdeprecation_warningswarningswarnDeprecationWarning isinstancerri startswithraro)rQros rH__init__WSTransport.__init__{sm    0 0 MMJ"  c6 " "c(C#s##3>>$+?+?>? ?rGrLrMc # SSKJn U"UR5IShvN nUupV[ XV40UD6IShvN nU7v SSS5IShvN SSS5IShvN g![an[S5UeSnAff=fNaNJN7!,IShvN (df  NL=fNC!,IShvN (df  g=f7f)Nr)websocket_clientzxThe websocket transport is not available. Please install fastmcp[websockets] or install the websockets package manually.)mcp.client.websocketr ImportErrorror )rQrLre transport read_stream write_streamsessions rHrRWSTransport.connect_sessions  = $DHH--(1 %K$-; .--  K   ..---sB>A$B>BB>B$BB$B B$BB$ B>B"B>$ A?. A::A??B>B$B$B B B B$"B>$B;*B- + B;7B>c"SURS3$)NzrorXs rHrYWSTransport.__repr__s*488*C88rGrN)r;r<r=r>r?rirr|rgrhrr1rr rRrYrFr:rGrHrmrmxsUQ C&L ## &} 5 } %$"9#9rGrmc 4\rSrSrSrSS\\-S\\\4S-S\R\ S-\-S-S\ R\ -\-S-S \S-4 S jjrS\R\ S-\-S-4S jr\R&S \\S \\4Sj5rS \4SjrSrg)r*zOTransport implementation that connects to an MCP server via Server-Sent Events.Nroheadersr^r_sse_read_timeouthttpx_client_factoryc[U[5(a [U5n[U[5(aURS5(d [ S5eXlU=(d 0UlURU5 XPl[U[[-5(a[R"[U5S9nX@l g)Nhttpz$Invalid HTTP/S URL provided for SSE.secondsrzrrir{rarorrcrintfloatr@rArrQrorr^rrs rHr|SSETransport.__init__s c6 " "c(C#s##3>>&+A+ACD D }"  t$8! &e 4 4'11%@P:QR  0rGcUS:Xa[UR5nO [U[5(a [ U5nXlgNr_rrorzrirr^rbs rHrcSSETransport._set_auth2 7??D c " "d#D rGrLrMc # 0n[5UR-US'URbURR5US'UR S5b<[ [ RUR S55nUR5US'URbURUS'[UR4SUR0UD6IShvN nUupV[XV40UD6IShvN nU7v SSS5IShvN SSS5IShvN gNCN,N!,IShvN (df  N.=fN%!,IShvN (df  g=f7fNrrr3timeoutrr^) rrr total_secondsgetr r@rArrror^r )rQrL client_kwargsr3rrrrs rHrRSSETransport.connect_sessions3)+ $4#5 #D i   ,040E0E0S0S0UM, -   4 5 A#'""N$6$67M$N$ (<'I'I'KM) $  $ $ 0484M4MM0 1dhhHTYYH-HHI(1 %K$-; IHHIHHHsCEDED?2D3D?6D#< D?D!D? ED=ED?!D?#D: )D,* D: 6D?=E?EE  EEc"SURS3$)Nzr?rirdictrjrkrr@rArrrr|rcrgrhrr1rr rRrYrFr:rGrHr*r*sY *.;?DH<@ 1 6\1c3h$&1jj77++c1D8 1 #,,u4s:TA 1 3T9 12ejj77+;;cADH## &} 5 } %$<3#3rGr*c 4\rSrSrSrSS\\-S\\\4S-S\R\ S-\-S-S\ R\ -\-S-S \S-4 S jjrS\R\ S-\-S-4S jr\R&S \\S \\4Sj5rS \4SjrSrg)r,zUTransport implementation that connects to an MCP server via Streamable HTTP Requests.Nrorr^r_rrc[U[5(a [U5n[U[5(aURS5(d [ S5eXlU=(d 0UlURU5 XPl[U[[-5(a[R"[U5S9nX@l g)Nrz0Invalid HTTP/S URL provided for Streamable HTTP.rrrs rHr| StreamableHttpTransport.__init__s c6 " "c(C#s##3>>&+A+AOP P }"  t$8! &e 4 4'11%@P:QR  0rGcUS:Xa[UR5nO [U[5(a [ U5nXlgrrrbs rHrc!StreamableHttpTransport._set_authrrGrLrMc L# 0n[5UR-US'URbURUS'URS5bURS5US'URbURUS'[ UR 4SUR0UD6IShvN nUupEn[XE40UD6IShvN nU7v SSS5IShvN SSS5IShvN gNDN,N!,IShvN (df  N.=fN%!,IShvN (df  g=f7fr) rrrrrrror^r )rQrLrrrr_rs rHrR'StreamableHttpTransport.connect_sessions#)+ $4#5 #D i   ,040E0EM, -   4 5 A'5'9'9:P'QM) $  $ $ 0484M4MM0 1( HH    +4 (Kq$-;          sB!D$#C($D$'D =C*>D C. D C,D  D$"D#D$*D ,D .D 4C75 D D D$ D!D  D!D$c"SURS3$)Nz>#>rGr,c\rSrSrSrSS\S\\S\\\4S-S\S-S\S-S \ \ -S-4 S jjr \ RS \\S \\4S j5rS \\S \S-4SjrSrSrSrS \4SjrSrg)r+i,z Base transport for connecting to an MCP server via subprocess with stdio. This is a base class that can be subclassed for specific command-based transports like Python, Node, Uvx, etc. Ncommandargsenvcwd keep_alivelog_filecXlX lX0lX@lUcSnXPlX`lSUlSUl[R"5Ul [R"5Ul g)a Initialize a Stdio transport. Args: command: The command to run (e.g., "python", "node", "uvx") args: The arguments to pass to the command env: Environment variables to set for the subprocess cwd: Current working directory for the subprocess keep_alive: Whether to keep the subprocess alive between connections. Defaults to True. When True, the subprocess remains active after the connection context exits, allowing reuse in subsequent connections. log_file: Optional path or file-like object where subprocess stderr will be written. Can be a Path or TextIO object. Defaults to sys.stderr if not provided. When a Path is provided, the file will be created if it doesn't exist, or appended to if it does. When set, server errors will be written to this file instead of appearing in the console. NT) rrrrrr_session _connect_taskanyioEvent _ready_event _stop_event)rQrrrrrrs rHr|StdioTransport.__init__4sX6    J$ .2 26!KKM ;;=rGrLrMc # UR"S0UD6IShvN [[UR57v UR(dUR 5IShvN g[ RS5 gNaN!UR(dUR 5IShvN f[ RS5 f=f7f)Nz6Stdio transport has keep_alive=True, not disconnectingr:)connectr r rr disconnectloggerdebugrPs rHrRStdioTransport.connect_session]s W,,00 0 0}dmm4 4??oo''' UV 1(??oo''' UVsICA?A;!A?$CA= C;A?=C?%C$B'%CCc.# URbg[R"5n[R"[ UR UR URURURUURURUS9 5UlURR5IShvN URR5(aURR5nUbUeUIShvN UlUR$N]N7f)N) rrrrrrL ready_event stop_eventsession_future)rasyncioFuture create_task_stdio_transport_connect_taskrrrrrrrwaitdone exceptionr)rQrLrrs rHrStdioTransport.connectjs    ) 8?8H%00 ) YYHHHH- --++-   $$&&&    " " $ $**446I$,, }} '-s%B1D3D4AD;D<DDc# URcgURR5 URIShvN SUl[R"5Ul[R"5UlgN@7fN)rrsetrrrrXs rHrStdioTransport.disconnectsd    %      " ;;=!KKM !s8A=A;AA=c@# UR5IShvN gN7fr)rrXs rHr\StdioTransport.closesoos cxURR5(dURR5 gg)zcEnsure that we send a disconnection signal to the transport task if we are being garbage collected.N)ris_setrrXs rH__del__StdioTransport.__del__s.&&((    ")rGcjSURRSURSURS3$)NrUz (command='z', args=z)>)rWr;rrrXs rHrYStdioTransport.__repr__s3''( 4<<. SU V rG) rrrrrrrrrrr)r;r<r=r>r?rilistrboolrrr|rgrhrr1rr rRrrr\rrYrFr:rGrHr+r+,s&*"&)-')')3i')#s(^d " ') 4Z ') 4K ')-$&')R## W &} 5 W } % W$ W! &} 5!  !F * #  # rGr+rrrrrrLrrrc (# [R"5IShvN n [UUUUS9n Uc[Rn O8[ U[ 5(a!U RURS55n OUn U R[XS95IShvN n U upURU R[X40UD65IShvN 5 [RS5 UR5 UR!5IShvN [RS5 SSS5IShvN gGNNNpN1![RS5 f=fN(!,IShvN (df  g=f!["a UR5 ef=f7f)zA standalone connection task for a stdio transport. It is not a part of the StdioTransport class to ensure that the connection task does not hold a reference to the Transport object.N)rrrra)errlogzStdio transport connectedzStdio transport disconnected)rgAsyncExitStackr sysstderrrzr enter_contextopenenter_async_contextr set_resultr rrrr Exception)rrrrrrLrrrstack server_paramslog_file_handlerrrs rHrrs\',,..%! = 5# ! #&)jjO$//&+&9&9(--:L&MO'/O"'";"; G# -6) ))33%kR>R  89!!oo''' ;[U5R5nUR5(d[SU35e[ U5R S5(d[ SU35e[ U5/nU(aURU5 [T U]%UUUUUUS9 Xl g)a Initialize a Python transport. Args: script_path: Path to the Python script to run args: Additional arguments to pass to the script env: Environment variables to set for the subprocess cwd: Current working directory for the subprocess python_cmd: Python command to use (default: "python") keep_alive: Whether to keep the subprocess alive between connections. Defaults to True. When True, the subprocess remains active after the connection context exits, allowing reuse in subsequent connections. log_file: Optional path or file-like object where subprocess stderr will be written. Can be a Path or TextIO object. Defaults to sys.stderr if not provided. When a Path is provided, the file will be created if it doesn't exist, or appended to if it does. When set, server errors will be written to this file instead of appearing in the console. Script not found: .pyNot a Python script: rrrrrrN rresolveis_fileFileNotFoundErrorriendswithraextendsuperr|r) rQrrrrrrr full_argsrWs rHr|PythonStdioTransport.__init__s:;'//1 ""$$#&8 $FG G;((//4[MBC C%&    T " !  'rGr)r;r<r=r>r?r executablerirrrrrr|rF __classcell__rWs@rHr)r)s/ "&%).."&)-/'4Z/'3i$/'#s(^d " /' 4Z /'  /'4K/'-$&/'/'rGr)c^\rSrSrSrS S\\-S\\S-S\\\4S-S\S-S\ S-S \\ -S-4 U4S jjjr S r U=r $) r%iz[U5R5nUR5(d[SU35e[ U5R S5(d[ SU35e[TU]!SS[ U5/UUUUS9 Xl g)Nrrrrtrunr) rrrrrirrarr|r)rQrrrrrrrWs rHr|FastMCPStdioTransport.__init__s;'//1 ""$$#&8 $FG G;((//4[MBC C [)*!  'rGr)NNNNNr;r<r=r>r?rirrrrrr|rFrrs@rHr%r%sF "&%)"&)-'4Z'3i$'#s(^d " ' 4Z ' 4K '-$&''rGr%c^\rSrSrSrS S\\-S\\S-S\\\4S-S\S-S\S \ S-S \\ -S-4U4S jjjr S r U=r $)r'i4z&Transport for running Node.js scripts.Nrrrrnode_cmdrrc P>[U5R5nUR5(d[SU35e[ U5R S5(d[ SU35e[ U5/nU(aURU5 [T U]%UUUUUUS9 Xl g)a Initialize a Node transport. Args: script_path: Path to the Node.js script to run args: Additional arguments to pass to the script env: Environment variables to set for the subprocess cwd: Current working directory for the subprocess node_cmd: Node.js command to use (default: "node") keep_alive: Whether to keep the subprocess alive between connections. Defaults to True. When True, the subprocess remains active after the connection context exits, allowing reuse in subsequent connections. log_file: Optional path or file-like object where subprocess stderr will be written. Can be a Path or TextIO object. Defaults to sys.stderr if not provided. When a Path is provided, the file will be created if it doesn't exist, or appended to if it does. When set, server errors will be written to this file instead of appearing in the console. r.jszNot a JavaScript script: rNr) rQrrrrrrrrrWs rHr|NodeStdioTransport.__init__7s:;'//1 ""$$#&8 $FG G;((//8 FG G%&    T " !  'rGr)NNNnodeNNr rs@rHr'r'4s0 "&%)"&)-/'4Z/'3i$/'#s(^d " /' 4Z /'  /'4K/'-$&/'/'rGr'c^\rSrSrSrSS\S\\S-S\S\S-S\S-S \\S-S \S-S \ \\4S-S \S-4U4S jjjr Sr U=r $)r-iiz/Transport for running commands via the uv tool.Nrrmoduleproject_directorypython_version with_packageswith_requirementsenv_varsrc >U(a#UR5(d[SU35e[UUUUSS9n /n U R5(aS/n U(aU R SU/5 U(aU R S[ U5/5 U=(d /Hn U R SU /5 M U(aU R S[ U5/5 OS/n U(aU R S5 U(d/nU R U/UQ5 Sn U(dU(aK[RR5n U(a[ U5U S 'U(aU RU5 [TU]1S U U SU S 9 g) NProject directory not found: )python dependencies requirementsprojecteditabler --pythonz --directory--withz--with-requirementsz--moduleUV_PROJECT_DIRuvrrrrr) existsNotADirectoryErrorr!_must_run_with_uvrriappendosenvironcopyupdaterr|)rQrrrrrrrrr env_configuv_argspkgrrWs rHr|UvStdioTransport.__init__lso %6%=%=%?%?$/0A/BC  #!&*%     ' ' ) )gG N;<  s3D/EFG%**#/+  5s;L7MNOgG  NN: &D'$'(&* (**//#C (+,=(>$% 8$ !  rGr:)NFNNNNNN) r;r<r=r>r?rirrrrr|rFrrs@rHr-r-is9 "&)-%)*.)-*."&I I 3i$I  I  $; I d I Cy4'I  $;I sCx.4'I 4KI I rGr-c^\rSrSrSrSS\S\\S-S\S-S\S-S\\S-S \S-S \\\4S-S \S-4U4S jjjr S r U=r $)r.iz0Transport for running commands via the uvx tool.N tool_name tool_argsrrr from_packagerrc >U(a,[U5R5(d[SU35e/n U(aU RSU/5 U(aU RSU/5 U=(d /Hn U RSU /5 M U R U5 U(aU RU5 Sn U(a/[ R R5n U RU5 [T U])SU U UUS9 Xl g)a Initialize a Uvx transport. Args: tool_name: Name of the tool to run via uvx tool_args: Arguments to pass to the tool project_directory: Project directory (for package resolution) python_version: Python version to use with_packages: Additional packages to include from_package: Package to install the tool from env_vars: Additional environment variables keep_alive: Whether to keep the subprocess alive between connections. Defaults to True. When True, the subprocess remains active after the connection context exits, allowing reuse in subsequent connections. rr"z--fromr#Nuvxr&) rr'r(rr*r+r,r-r.rr|r4) rQr4r5rrrr6rruvx_argsr1rrWs rHr|UvxStdioTransport.__init__s8 T*;%<%C%C%E%E$/0A/BC  !  OOZ8 9  OOX|4 5 &B&C OOXsO ,'  "  OOI &%) **//#C JJx  !!  (rG)r4)NNNNNNN r;r<r=r>r?rirrrr|rFrrs@rHr.r.s: '+(,%)*.#'*."&;(;(9t#;(: ;( d ;( Cy4' ;(Dj;(sCx.4';(4K;(;(rGr.c~^\rSrSrSrS S\S\\S-S\S-S\\\4S-S\S \S-4 U4S jjjr S r U=r $) r(iz0Transport for running commands via the npx tool.Npackagerrruse_package_lockrc>[R"S5c [S5eU(a,[U5R 5(d[ SU35e/nU(aUR S5 UR U5 U(aURU5 SnU(a/[RR5nURU5 [T U]5SUUUUS9 Xlg)a8 Initialize an Npx transport. Args: package: Name of the npm package to run args: Arguments to pass to the package command project_directory: Project directory with package.json env_vars: Additional environment variables use_package_lock: Whether to use package-lock.json (--prefer-offline) keep_alive: Whether to keep the subprocess alive between connections. Defaults to True. When True, the subprocess remains active after the connection context exits, allowing reuse in subsequent connections. npxNzCommand 'npx' not foundrz--prefer-offliner&)shutilwhichrarr'r(r*rr+r,r-r.rr|r=) rQr=rrrr>rnpx_argsrrWs rHr|NpxStdioTransport.__init__s0 <<  &67 7 T*;%<%C%C%E%E$/0A/BC    OO. /   OOD ! **//#C JJx  !!   rG)r=)NNNTNr;rs@rHr(r(sy: "&(,*.!%"&883i$8: 8 sCx.4' 8  84K88rGr(c~\rSrSrSrS S\\-S\4Sjjr\ RS\ \ S\ \4Sj5rS\4S jrS rg ) r&i7aHIn-memory transport for FastMCP servers. This transport connects directly to a FastMCP server instance in the same Python process. It works with both FastMCP 2.x servers and FastMCP 1.0 servers from the low-level MCP SDK. This is particularly useful for unit tests or scenarios where client and server run in the same runtime. rCraise_exceptionscXlX lg)z=Initialize a FastMCPTransport from a FastMCP server instance.N)serverrF)rQrCrFs rHr|FastMCPTransport.__init__@s  0rGrLrMc ^^^ # [5IShvN unnUupEUumm [R"5IShvN n[TRS9IShvN UR UUU 4Sj5 [ SUUS.UD6IShvN nU7v SSS5IShvN URR5 SSS5IShvN SSS5IShvN SSS5IShvN gNNNNjNW!,IShvN (df  Nl=f!URR5 f=fNh!,IShvN (df  N}=fNt!,IShvN (df  N=fN!,IShvN (df  g=f7f)NrHc>TRRRTTTRRR5TRS9$)N)rF)rH _mcp_serverr create_initialization_optionsrF)rQ server_read server_writesrH2FastMCPTransport.connect_session..ZsDDKK3377#$ //MMO)-)>)> 8rG)rrr:) rrcreate_task_group_enter_server_lifespanrH start_soonr cancel_scopecancel) rQrLclient_streamsserver_streams client_read client_writetgclient_sessionrOrPs ` @@rHrR FastMCPTransport.connect_sessionIs&788=  (6 %K(6 %K''))R&dkk:: -, $/%1 )  (,,   OO**,';:*)988*:    OO**,';:::*)))9888s2FC.F&E+C0E+EC2 ED37D C4 D C8  DC6 D#D3= ED1 E E+E E+ F(E))F0E+2E4D6D8D >D? D DD. .D31E3E 9D<: E E E+E& E E& "E+)F+F1E4 2 F>Fc6SURRS3$)Nzr?rFastMCP1Serverrr|rgrhrr1rr rRrirYrFr:rGrHr&r&7sb1Gn411## - &} 5 - } % -$ -DB#BrGr&rHrMc# [U[5(a/UR5IShvN S7v SSS5IShvN gS7v gN N !,IShvN (df  g=f7f)z`Enters the server's lifespan context for FastMCP servers and does nothing for FastMCP 1 servers.N)rzr_lifespan_managerrKs rHrTrTpsD &'""++-- .-- .---sC*A+A A+A A+A A+A+A(A  A($A+c\rSrSrSrS S\\-S\4Sjjr\ RS\ \ S\ \4Sj5rS rS\4S jrS rg )MCPConfigTransporti|aTransport for connecting to one or more MCP servers defined in an MCPConfig. This transport provides a unified interface to multiple MCP servers defined in an MCPConfig object or dictionary matching the MCPConfig schema. It supports two key scenarios: 1. If the MCPConfig contains exactly one server, it creates a direct transport to that server. 2. If the MCPConfig contains multiple servers, it creates a composite client by mounting all servers on a single FastMCP instance, with each server's name, by default, used as its mounting prefix. In the multi-server case, tools are accessible with the prefix pattern `{server_name}_{tool_name}` and resources with the pattern `protocol://{server_name}/path/to/resource`. This is particularly useful for creating clients that need to interact with multiple specialized MCP servers through a single interface, simplifying client code. Examples: ```python from fastmcp import Client from fastmcp.utilities.mcp_config import MCPConfig # Create a config with multiple servers config = { "mcpServers": { "weather": { "url": "https://weather-api.example.com/mcp", "transport": "http" }, "calendar": { "url": "https://calendar-api.example.com/mcp", "transport": "http" } } } # Create a client with the config client = Client(config) async with client: # Access tools with prefixes weather = await client.call_tool("weather_get_forecast", {"city": "London"}) events = await client.call_tool("calendar_list_events", {"date": "2023-06-01"}) # Access resources with prefixed URIs icons = await client.read_resource("weather://weather/icons/sunny") ``` configname_as_prefixc:SSKJn [U[5(a[R "U5nXl/Ul[UR R5S:Xa [S5e[UR R5S:Xao[[UR RR555R5UlURR!UR5 g["R$"S5n["[&"US9UlU"UR 5HCupEnURR!U5 UR(R+XR(aUOSS9 ME [-UR(S9Ulg) Nr)$mcp_config_to_servers_and_transportsz$No MCP servers defined in the config MCPRouter)r`)prefixrC)fastmcp.utilities.mcp_configrjrzrr from_dictrg_underlying_transportslen mcpServersranextitervalues to_transportrr*r generate_namer_composite_servermountr&)rQrgrhrjr`rHrs rHr|MCPConfigTransport.__init__s<U fd # #((0F =?# t{{%% &! +CD D'' (A -!$t{{'='='D'D'F"GHUUWDN  ' ' . .t~~ >((5D%,S\t%4t- ,.$2H2HIDNrGrLrMc # URR"S0UD6IShvN nU7v SSS5IShvN gNN!,IShvN (df  g=f7f)Nr:)rrR)rQrLrs rHrR"MCPConfigTransport.connect_sessions;>>11CNCCwMDCCCCCs@!A>AA AAAAAA AAcf# URHnUR5IShvN M gN 7fr)rqr\)rQrs rHr\MCPConfigTransport.closes(44I//# # #5 #s #1/ 1c"SURS3$)Nz>rG)ryrqrgrN)T)r;r<r=r>r?rrrr|rgrhrr1rr rRr\rirYrFr:rGrHrfrf|si-^Jy4/JJB## &} 5 } %$ $?#?rGrfrcgrr:rs rHr/r/FIrGcgrr:rs rHr/r/s=@rGcgrr:rs rHr/r/sDGrGcgrr:rs rHr/r/sADrGcgrr:rs rHr/r/rrGcgrr:rs rHr/r/s.1rGcgrr:rs rHr/r/s rGcgrr:rs rHr/r/sSVrGc([U[5(aU$[U[[-5(a'[ [ [[ [-U5S9nGO[U[[-5(a[U5R5(a}[U5RS5(a[[ [U5S9nGO-[U5RS5(a[[ [U5S9nO[SU35e[U[[-5(a[U5RS5(ad[![ [[-U55nUS:Xa[#[ [[-U5S9nOh[%[ [[-U5S9nOI[U[&[(-5(a[+[ [&[(-U5S 9nO[S U35e[,R/S U35 U$) a Infer the appropriate transport type from the given transport argument. This function attempts to infer the correct transport type from the provided argument, handling various input types and converting them to the appropriate ClientTransport subclass. The function supports these input types: - ClientTransport: Used directly without modification - FastMCP or FastMCP1Server: Creates an in-memory FastMCPTransport - Path or str (file path): Creates PythonStdioTransport (.py) or NodeStdioTransport (.js) - AnyUrl or str (URL): Creates StreamableHttpTransport (default) or SSETransport (for /sse endpoints) - MCPConfig or dict: Creates MCPConfigTransport, potentially connecting to multiple servers For HTTP URLs, they are assumed to be Streamable HTTP URLs unless they end in `/sse`. For MCPConfig with multiple servers, a composite client is created where each server is mounted with its name as prefix. This allows accessing tools and resources from multiple servers through a single unified client interface, using naming patterns like `servername_toolname` for tools and `protocol://servername/path` for resources. If the MCPConfig contains only one server, a direct connection is established without prefixing. Examples: ```python # Connect to a local Python script transport = infer_transport("my_script.py") # Connect to a remote server via HTTP transport = infer_transport("http://example.com/mcp") # Connect to multiple servers using MCPConfig config = { "mcpServers": { "weather": {"url": "http://weather.example.com/mcp"}, "calendar": {"url": "http://calendar.example.com/mcp"} } } transport = infer_transport(config) ``` rnrrrzUnsupported script type: rsserrz(Could not infer a valid transport from: zInferred transport: )rzr#rrbr&r rrrir'rr)r'rarr{rr*r,rrrfrr)rinferred_transportinferred_transport_types rHr/r/sh)_-- Iw7 8 8-WS\N2I>  Itcz * *tI/E/E/G/G y> " "5 ) )!5$tYBW!X  ^ $ $U + +!3T9@U!V 8 DE E Iv| , ,Y1J1J61R1R"? #y )#  #e +!-$v|Y2O!P !8#y1"  Iti/ 0 0/y()4  CI;OPP LL'(:';<= rG)\rerrgr@r+rArrwcollections.abcrpathlibrtypingrrrrr r rrj mcp.typesrCr r mcp.client.sessionr rrrrmcp.client.ssermcp.client.stdiormcp.client.streamable_httprmcp.server.fastmcprrbmcp.shared._httpx_utilsrmcp.shared.memoryrpydanticrtyping_extensionsrrrtfastmcp.client.auth.bearerrfastmcp.client.auth.oauthrfastmcp.mcp_configrrfastmcp.server.dependenciesrfastmcp.server.serverfastmcp.utilities.loggingr 6fastmcp.utilities.mcp_server_config.v1.environments.uvr!r;rr"__all__r1ABCr#rmr*r,r+rirrrrrr)r%r'r-r.r(r&rhrTrfr/r:rGrHrs  )@@ 4&)<88A/1+G8)0P H -5FG  1IU 1*Ecgg*EZ$9/$9NC3?C3LD>oD>N{ _{ |5 5 s)5 c3h$ 5 t 5 Vmd" 5 " 55 5NN=15p2'>2'j'N':2'2'jL ~L ^>(>(B;;|6B6Br  n $4 ]?]?@ I/I4DI I @w@+;@ @ G~G2BG G DyD-?D D ItCH~I2DI I 11++1 1  --