k7i"SSKJr SSKrSSKrSSKrSSKrSSKrSSKJrJ r J r SSK J r J r Jr SSKJrJrJr SSKJrJr SSKrSSKrSSKJr SSKJr SS KJr \(aSS KJr \ SS j5r SS jr!\ S SSS.SSjj5r"\ SSSjj5r#\ S5r$"SS\5r%g)) annotationsN)AsyncGeneratorCallable Generator)asynccontextmanagercontextmanagersuppress) TYPE_CHECKINGAnyLiteral)parse_qsurlparse)settings)OAuth)find_available_port)FastMCPc +j# [R"[5nUR5Hup#[R"X#5 M Sv UH(n[R"X!R U55 M* g!UH(n[R"X!R U55 M* f=f7f)a Temporarily override FastMCP setting values. Args: **kwargs: The settings to override, including nested settings. Example: Temporarily override a setting: ```python import fastmcp from fastmcp.utilities.tests import temporary_settings with temporary_settings(log_level='DEBUG'): assert fastmcp.settings.log_level == 'DEBUG' assert fastmcp.settings.log_level == 'INFO' ``` N)copydeepcopyritems set_setting get_setting)kwargs old_settingsattrvalues Q/home/james-whalen/.local/lib/python3.13/site-packages/fastmcp/utilities/tests.pytemporary_settingsrs&==*L G!<<>KD   -* D  '?'?'E FFD  '?'?'E FsB33B/B30B00B3c US:XaURSS9nO[SU35e[R"[R"USUSSS9S9nUR 5 g) Nsse) transportzInvalid transport: 127.0.0.1errorzwebsockets-sansio)apphostport log_levelws)config)http_app ValueErroruvicornServerConfigrun) mcp_serverr!r&r$uvicorn_servers r _run_serverr29sgE!!E!2.yk:;;^^~~"  NTr")provide_host_and_portr%r&c/# Uc [5nU(aXRUS.-n[R"XUSS9nUR5 SnSnX:afUR 5(aQ[ R "[ R [ R5n U RX#45 SSS5 O[S US35eSUSU3v UR5 URSS9 UR 5(a@UR5 URSS9 UR 5(a [S5egg!,(df  Oh=f![aX US:a[R"S5 O3US :a[R"S 5 O[R"S 5 US - nOf=fX:dGM UR 5(aGMuGN&7f)a Context manager that runs a FastMCP server in a separate process and returns the server URL. When the context manager is exited, the server process is killed. Args: server_fn: The function that runs a FastMCP server. FastMCP servers are not pickleable, so we need a function that creates and runs one. *args: Arguments to pass to the server function. provide_host_and_port: Whether to provide the host and port to the server function as kwargs. host: Host to bind the server to (default: "127.0.0.1"). port: Port to bind the server to (default: find available port). **kwargs: Keyword arguments to pass to the server function. Returns: The server URL. N)r%r&T)targetargsrdaemonrg?皙?g?zServer failed to start after z attemptshttp://:)timeoutz2Server process failed to terminate even after kill)rmultiprocessingProcessstartis_alivesocketAF_INET SOCK_STREAMconnectConnectionRefusedErrortimesleep RuntimeError terminatejoinkill) server_fnr4r%r&r7rproc max_attemptsattemptss rrun_server_in_processrVKs4 |"$..  " "F4 D JJLLG  T]]__ v~~v/A/ABa 4,'CB:<. RSS D64& !!NNIIaI }}  !  ==??ST T  %CB& { 4 2 3 3 qLG   T]]__sVA G#3EE*E2BG E EGEAF41G3F44G?Gc .# SSKnUc [5nURS5IShvN URUR UUUUSS95nURS5IShvN SUSUU37v UR 5 [ UR5 UIShvN SSS5 gNNMN!,(df  g=f!UR 5 [ UR5 UIShvN SSS5 f!,(df  f=f=f7f) a Start a FastMCP server as an asyncio task for in-process async testing. This is the recommended way to test FastMCP servers. It runs the server as an async task in the same process, eliminating subprocess coordination, sleeps, and cleanup issues. Args: server: FastMCP server instance port: Port to bind to (default: find available port) transport: Transport type ("http", "streamable-http", or "sse") path: URL path for the server (default: "/mcp") host: Host to bind to (default: "127.0.0.1") Yields: Server URL string Example: ```python import pytest from fastmcp import FastMCP, Client from fastmcp.client.transports import StreamableHttpTransport from fastmcp.utilities.tests import run_server_async @pytest.fixture async def server(): mcp = FastMCP("test") @mcp.tool() def greet(name: str) -> str: return f"Hello, {name}!" async with run_server_async(mcp) as url: yield url async def test_greet(server: str): async with Client(StreamableHttpTransport(server)) as client: result = await client.call_tool("greet", {"name": "World"}) assert result.content[0].text == "Hello, World!" ``` rNg{Gz?F)r%r&r!path show_bannerr<r>r?)asynciorrL create_taskrun_http_asynccancelr CancelledError)serverr&r!rXr%rZ server_tasks rrun_server_asyncrasb |"$ -- %%  K -- vQtfTF++  g,, -  . -+ . -  g,, -  . - -s&DB/:D#B1$D) C6%DB5!B3"B5& D1D3B55 C?D&D,D2C5 3D8 D D DDc## UR5 [R"S5nURUR5 Uv UR UR5 g!UR UR5 f=f7f)zWContext manager to capture logs from FastMCP loggers even when propagation is disabled.fastmcpN)clearlogging getLogger addHandlerhandler removeHandler)caplogloggers rcaplog_for_fastmcprls` LLN   y )F fnn%- V^^,V^^,sABA% B%BBcD^\rSrSrSrSU4SjjrSSjrS SjrSrU=r $) HeadlessOAuthz OAuth provider that bypasses browser interaction for testing. This simulates the complete OAuth flow programmatically by making HTTP requests instead of opening a browser and running a callback server. Useful for automated testing. c 6>SUl[TU]"U40UD6 g)z7Initialize HeadlessOAuth with stored response tracking.N)_stored_responsesuper__init__)selfmcp_urlr __class__s rrsHeadlessOAuth.__init__s $ +F+r3c# [R"5IShvN nURUSS9IShvN nX0lSSS5IShvN gN3NN !,IShvN (df  g=f7f)zOMake HTTP request to authorization URL and store response for callback handler.NF)follow_redirects)httpx AsyncClientgetrq)rtauthorization_urlclientresponses rredirect_handlerHeadlessOAuth.redirect_handlersN$$&&&#ZZ(9EZRRH$, !'&&R'&&&sSA0AA0AA A A0 A A0AA0A-A  A-)A0c# UR(d [S5eURnURS:XaURSn[ U5n[ UR 5nSU;a/USSnURSS/5Sn[SUS U35eUS SnURS S /5SnXx4$[S UR35e7f)z4Parse stored response and return (auth_code, state).zHNo authorization response stored. redirect_handler must be called first.i.locationr#rerror_descriptionz Unknown errorzOAuth authorization failed: z - codestateNzAuthorization failed: )rqrM status_codeheadersrr queryr|) rtr redirect_urlparsed query_paramsr# error_desc auth_coders rcallback_handlerHeadlessOAuth.callback_handlers$$Z ((   3 &#++J7Ll+F#FLL1L,&$W-a0)--.AOCTUVWX "25'ZLI%V,Q/I $$Wtf5a8E# #!78L8L7MNO OsCC)rq)rustr)r}rreturnNone)rztuple[str, str | None]) __name__ __module__ __qualname____firstlineno____doc__rsrr__static_attributes__ __classcell__)rvs@rrnrns, - PPr3rn)rr )r0rr!zLiteral['sse']r&intrr)rQzCallable[..., None]r7r r4boolr%rr& int | Nonerr rzGenerator[str, None, None])Nhttpz/mcpr") r_rr&rr!z)Literal['http', 'streamable-http', 'sse']rXrr%rrzAsyncGenerator[str, None])& __future__rrrerBrFrKcollections.abcrrr contextlibrrr typingr r r urllib.parser rrzr,rcrfastmcp.client.auth.oauthrfastmcp.utilities.httprfastmcp.server.serverrrr2rVrarlrnr3rrsV"  ??DD..+ +6-GG@$#' @U"@U @U @U  @U  @U  @U @U@UF;A L L L9L  L  L  LL^---PE-Pr3