"j%J%SSKJr SSKrSSKrSSKrSSKrSSKJrJ r SSK J r J r SSK JrJrJrJrJrJr SSKJrJr SSKJr SSKJr S S KJr \(aSS KJr \"S S 9rSr S\!S'SSKJrJ"r" SSK#J$r$ \$"5r%Sr&\&\%RN;deS$Sjr(S%Sjr*S&Sjr+\"S5r,S'Sjr-S(Sjr.S)Sjr/S*Sjr0"SS5r1\1"5r2SSK3J4r4 \(a \Rlr7O \ S+S"j5r7S,S#jr8g!\)a S$Sjr(Nof=f!\)a "S S!\55r4NHf=f)-) annotationsN) Awaitable Generator)contextmanagersuppress) TYPE_CHECKINGAny TypeAliasTypeVarget_args get_origin)Logfire LogfireSpan)typing_objects)is_union_origin)UnsupportedEventLoopError)Spanzpydantic-graph) otel_scopezLogfireSpan | Spanr AbstractSpan)rset_span_in_context)TraceContextTextMapPropagator traceparentc[U[5(aUnOURnU(de[U5n0n[R X25 UR [S5$)zGGet a string representing the span context to use for annotating spans.) isinstancer_spanrTRACEPARENT_PROPAGATORinjectgetTRACEPARENT_NAME)span real_spancontextcarriers R/home/mande/repo/quber/.venv/lib/python3.13/site-packages/pydantic_graph/_utils.pyget_traceparentr'!sV dD ! !I I 9%i0"$%%g7{{+R00cgN)r"s r&r'r'0sr(cd[URSS5[RRL$)aWhether `loop` actually implements `run_until_complete()`. `asyncio.AbstractEventLoop` declares `run_until_complete()` but its body just raises a bare `NotImplementedError`. Event loops that can only be driven by their own runtime -- like Temporal's workflow loop -- inherit that method without overriding it, so we check for the inherited method up front. Catching `NotImplementedError` around the call instead would also swallow one raised by the coroutine we're running, i.e. by the caller's own code. __func__N)getattrrun_until_completeasyncioAbstractEventLooploops r&_implements_run_until_completer45s* 4**J =WE^E^EqEq qqr(c[R"5nUb[U5(dU$UbUR 5(a+[R "5n[R "U5 U$![a SnNhf=fr*)r0get_event_loop RuntimeErrorr4 is_closednew_event_loopset_event_loop) event_loops r&r6r6As|++- &DZ&P&P Z1133++- z*   sA11 B?B_Tc[5n[U5(dM[R"U5(aUR 5 [ S[ U5RS35e[R"XS9nURU5$![ab UR5(dKUR5 [[5 URU5 SSS5 e!,(df  e=fef=f)aPRun `coro` to completion on the event loop, cleaning up after itself if interrupted. If the caller interrupts `loop.run_until_complete()` (e.g. by pressing Ctrl-C, raising `KeyboardInterrupt`) while `coro` is suspended, asyncio leaves its task pending with its `async with`/`finally` blocks un-run, leaking the task and any open connections. We cancel *our own* task and drive its cleanup to completion before re-raising, without touching any other tasks on the (caller-owned) loop. Raises: UnsupportedEventLoopError: If the current event loop doesn't implement `run_until_complete()`. zThe current event loop (aA) does not implement `run_until_complete()`, which synchronous methods need in order to run their asynchronous implementation. This is the case inside a Temporal workflow, whose event loop can only be driven by Temporal itself. Use the asynchronous method instead, e.g. `await agent.run()` rather than `agent.run_sync()`.r2N)r6r4inspect iscoroutineclosertype__name__r0 ensure_futurer/ BaseExceptiondonecancelr)coror3tasks r&r/r/Xs  D )$ / /   t $ $ JJL'&tDz':':&;C: C' C:' C5 1 C:c[R"U5(a URn[U5n[ U5(a [ U5$U4$)zeExtract the arguments of a Union type if `response_type` is a union, otherwise return an empty tuple.)ris_typealiastype __value__r rr )tporigins r&get_union_argsrN|sC&&r** \\ ^Fv|u r(ct[U5n[R"U5(a[U5tp#X#4$U/4$)zStrip `Annotated` from the type if present. Returns: `(tp argument, ())` if not annotated, otherwise `(stripped type, annotations)`. )r r is_annotatedr )rLrMinner_tpargss r&unpack_annotatedrSs: ^F""6**"2,~2v r(cUbJUR=n(a6URRS5S:Xa [U5$UR$gg)agAttempt to get the namespace where the graph was defined. If the graph is defined with generics `Graph[a, b]` then another frame is inserted, and we have to skip that to get the correct namespace. Args: frame: The frame to start searching from, or `None`. Returns: The local namespace dict of the defining frame, or `None` if the frame was `None`. NrBtyping)f_back f_globalsr get_parent_namespacef_locals)framebacks r&rXrXsQ << 4 ~~!!*-9 ,D11}}$ r(c\rSrSrSrSrg)UnsetzMA singleton to represent an unset value. Copied from pydantic_ai/_utils.py. r+N)rB __module__ __qualname____firstlineno____doc____static_attributes__r+r(r&r]r]s   r(r])LogfireNotConfiguredWarningc\rSrSrSrg)rdr+N)rBr_r`rarcr+r(r&rdrds r(rdc/# [R"5 [R"S[S9 [R "U0UD6nUv SSS5 SSS5 g!,(df  N=f!,(df  g=f7f)zCCreate a Logfire span without warning if logfire is not configured.ignore)categoryN)warningscatch_warningsfilterwarningsrd_logfirer")rRkwargsr"s r& logfire_spanrosX  $ $ &  # #H7R S//4 0' &//' &s4B0A/A A/ B A, (A// A=9Bc\[R"5nUcg[U5HnURnUbM g URR 5H upEXPLdM Us $ URUR :wa+UR R 5H upEXPLdM Us $ g)a)Infer the variable name of an object from the calling frame's scope. This function examines the call stack to find what variable name was used for the given object in the calling scope. This is useful for automatic naming of objects based on their variable names. Args: obj: The object whose variable name to infer. depth: Number of stack frames to traverse upward from the current frame. Returns: The inferred variable name if found, None otherwise. Example: Usage should generally look like `infer_name(self, depth=2)` or similar. N)r> currentframerangerVrYitemsrW)objdepth target_frame_nameitems r&infer_obj_namerzs"'')L 5\#**   #++113  ;K4 6 66&00668JD{ 9 r()r"rreturn str | None)r3asyncio.AbstractEventLoopr{bool)r{r})rGz Awaitable[_T]r{r<)rLr r{ztuple[Any, ...])rLr r{ztuple[Any, list[Any]])rZztypes.FrameType | Noner{zdict[str, Any] | None)rRr rnr r{z"Generator[LogfireSpan, None, None])rtr ruintr{r|)9 __future__r _annotationsr0r>typesrjcollections.abcrr contextlibrrrUrr r r r r logfire_apirrtyping_inspectionrtyping_inspection.introspectionr exceptionsropentelemetry.tracerrmr__annotations__r,opentelemetry.trace.propagation.tracecontextrrr!fieldsr' ImportErrorr4r6r<r/rNrSrXr]UNSETlogfire._internal.configrd UserWarningr"rorzr+r(r&rs2 0/OO,,;1( . /. i.=Z:<$ 5<< << < 1( r( T]!H  %0    ==L#Mb  k  s$-.C=D= D  D D"!D"