k7i/8%SSKJr SSKJrJrJr SSKJrJr SSK J r SSK J r SSK Jr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJ r J!r!J"r" SSK#J$r$J%r%J&r&J'r' SSK(J)r) SSK*J+r+ SSK,J-r- \ (aSSK.J/r/ \-"\05r1"SS5r2\ "SSS9r3S\4S'"SS\5r5\S$Sj5r6"SS 5r7S%S&S!jjr8S'S(S"jjr9S)S*S#jjr:g)+) annotations)AsyncGeneratorCallable Generator)asynccontextmanagercontextmanager) ContextVar) TYPE_CHECKING)build_resource_metadata_url)LifespanResultT)SseServerTransport) EventStore)StreamableHTTPSessionManager) Starlette) Middleware)Request)Response) BaseRouteMountRoute)LifespanReceiveScopeSend) AuthProvider)RequireAuthMiddleware) get_logger)FastMCPc(\rSrSrSrSrSSjrSrg)StreamableHTTPASGIApp z>ASGI application wrapper for Streamable HTTP server transport.cXlgNsession_manager)selfr%s M/home/james-whalen/.local/lib/python3.13/site-packages/fastmcp/server/http.py__init__StreamableHTTPASGIApp.__init__#s.c# URRXU5IShvN gN![a?n[U5S:Xa*[R SU3SS9 Sn[USU35UeeSnAff=f7f)Nz6Task group is not initialized. Make sure to use run().z(Original RuntimeError from mcp library: T)exc_infoaFastMCP's StreamableHTTPSessionManager task group was not initialized. This commonly occurs when the FastMCP application's lifespan is not passed to the parent ASGI application (e.g., FastAPI or Starlette). Please ensure you are setting `lifespan=mcp_app.lifespan` in your parent app's constructor, where `mcp_app` is the application instance returned by `fastmcp_instance.http_app()`. \nFor more details, see the FastMCP ASGI integration documentation: https://gofastmcp.com/deployment/asgiz\nOriginal error: )r%handle_request RuntimeErrorstrloggererror)r&scopereceivesendenew_error_messages r'__call__StreamableHTTPASGIApp.__call__&s &&55edK K K 1vQQ >qcBT<"#&7%88KA3#OPVWW) s0A7+)+A7+ A4:A//A44A7r$N)r2rr3rr4rreturnNone__name__ __module__ __qualname____firstlineno____doc__r(r7__static_attributes__r*r'r r sH/r*r http_requestN)defaultzContextVar[Request | None]_current_http_requestc(\rSrSr\SSj5rSrg)StarletteWithLifespanFc.URR$r#)routerlifespan_context)r&s r'lifespanStarletteWithLifespan.lifespanGs{{+++r*rBN)r9zLifespan[Starlette])r<r=r>r?propertyrLrArBr*r'rGrGFs ,,r*rGc## [RU5nUv [RU5 g![RU5 f=f7fr#)rEsetreset)requesttokens r'set_http_requestrTLs< ! % %g .E+ ##E*##E*sA 3A A  A c$\rSrSrSrSrSrSrg)RequestContextMiddlewareUz5 Middleware that stores each request in a ContextVar cXlgr#app)r&rZs r'r(!RequestContextMiddleware.__init__Zsr*c# USS:Xa8[[U55 URXU5IShvN SSS5 gURXU5IShvN gN(!,(df  g=fN7f)Ntypehttp)rTrrZ)r&r2r3r4s r'r7!RequestContextMiddleware.__call__]sb =F "!'%.1hhut44421((540 0 0521 1s7A4A!AA!A4A2A4A!! A/+A4rYNr;rBr*r'rVrVUs1r*rVcXURS[[55 [UUUUS9$)a2Create a base Starlette app with common middleware and routes. Args: routes: List of routes to include in the app middleware: List of middleware to include in the app debug: Whether to enable debug mode lifespan: Optional lifespan manager for the app Returns: A Starlette application rroutes middlewaredebugrL)insertrrVrGras r'create_base_apprfes3$a$<=>   r*c ^^^/n/n[U5mS UU4SjjmU(aUR5n URUS9n URU 5 URU 5 UR U5n U (a [ U 5OSn UR [U[TURU 5S/S95 UR [U[TRURU 5S95 OFS U4Sjjn UR [UU S/S95 UR [UTRS95 U(aURU5 URTR55 U(aURU5 [S U4Sjj5n[UUUUS 9nTURlX/RlU$) aReturn an instance of the SSE server app. Args: server: The FastMCP server instance message_path: Path for SSE messages sse_path: Path for SSE connections auth: Optional authentication provider (AuthProvider) debug: Whether to enable debug mode routes: Optional list of custom routes middleware: Optional list of middleware Returns: A Starlette application with RequestContextMiddleware cN># TRXU5IShvN nTRRUSUSTRR55IShvN SSS5IShvN [ 5$NaN N!,IShvN (df  [ 5$=f7f)Nr) connect_sse _mcp_serverruncreate_initialization_optionsr)r2r3r4streamsserversses r' handle_sse"create_sse_app..handle_sses??5488G$$((  ""@@B  98 z 9 988 zsVB%A<B%?BA>B" B%-B.B%>BB%B"B B"B%mcp_pathNGETendpointmethodsrYcp># T"URURUR5IShvN $N7fr#)r2r3_send)rRrqs r' sse_endpoint$create_sse_app..sse_endpoints'#GMM7??GMMRR RRs ,646c># TR5IShvN S7v SSS5IShvN gNN!,IShvN (df  g=f7fr#)_lifespan_manager)rZros r'rL create_sse_app..lifespans,++-- .-----s:A3A7 A5AAAA A Ara)r2rr3rr4rr9r)rRrr9rrZrr9zAsyncGenerator[None, None])r get_middleware get_routesextend_get_resource_urlr appendrrrequired_scopesrhandle_post_message_get_additional_http_routesrrfstatefastmcp_serverpath)ro message_pathsse_pathauthrdrbrc server_routesserver_middlewareauth_middleware auth_routes resource_urlresource_metadata_urlr{rLrZrqrps` @@r'create_sse_apprs.&(M*, \ *C --/ooxo8 [)  1--h7 9E ' 54   .(()     )++(()   S  %    ++  V$;;=>  , $  C &CIIIIN Jr*c ^^/n /n [TRUUUS9m[T5n U(aUR5n UR US9n U R U 5 U R U 5 UR U5nU(a [U5OSnU R[U[U URU5/SQS95 OU R[UU S95 U(aU R U5 U R TR55 U(aU R U5 [S UU4Sjj5n[U U UUS9nTURlUURlU$) a_Return an instance of the StreamableHTTP server app. Args: server: The FastMCP server instance streamable_http_path: Path for StreamableHTTP connections event_store: Optional event store for session management auth: Optional authentication provider (AuthProvider) json_response: Whether to use JSON response format stateless_http: Whether to use stateless mode (new transport per request) debug: Whether to enable debug mode routes: Optional list of custom routes middleware: Optional list of middleware Returns: A Starlette application with StreamableHTTP support )rZ event_store json_response statelessrsN)ruPOSTDELETErv)rwc4># TR5IShvN TR5IShvN S7v SSS5IShvN SSS5IShvN gNCN,N!,IShvN (df  N.=fN%!,IShvN (df  g=f7fr#)r~rl)rZror%s r'rL,create_streamable_http_app..lifespanWsQ++--/B/B/D/D 0E/D---/D/D/D/D----sBABA>AA>A" A>A A> BA<BA> A>"A9 (A+) A9 5A><B>BB  BBrar)rrkr rrrrr rrrrrrrfrrr)rostreamable_http_pathrrrstateless_httprdrbrcrrstreamable_http_apprrrrrLrZr%s` @r'create_streamable_http_apprs~6&(M*,3   # O0@ --/oo/CoD [)  1--.BC 9E ' 54   $.'(() 2    $,  V$;;=>  , $  C &CII)CIIN Jr*)rRrr9zGenerator[Request, None, None])FN) rbzlist[BaseRoute]rczlist[Middleware]rdboolrLzCallable | Noner9rG)NFNN)roFastMCP[LifespanResultT]rr/rr/rAuthProvider | Nonerdrrblist[BaseRoute] | Nonerclist[Middleware] | Noner9rG)NNFFFNN)rorrr/rzEventStore | Nonerrrrrrrdrrbrrcrr9rG); __future__rcollections.abcrrr contextlibrr contextvarsr typingr mcp.server.auth.routesr mcp.server.lowlevel.serverr mcp.server.sser mcp.server.streamable_httpr"mcp.server.streamable_http_managerrstarlette.applicationsrstarlette.middlewarerstarlette.requestsrstarlette.responsesrstarlette.routingrrrstarlette.typesrrrrfastmcp.server.authrfastmcp.server.auth.middlewarerfastmcp.utilities.loggingrfastmcp.server.serverrr<r0r rE__annotations__rGrTrVrfrrrBr*r'rs"??:" >6-L,+&(55::,@0- H @5? 51 ,I, ++ 1 1& $       @!%%)*.{ ${{{  {  { # {({{B&* $ %)*.i $ii#i  i  i  i i #i(iir*