o i~@sUddlmZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZmZmZmZmZddlmZmZddlmZmZdd lmZdd lmZer_dd lm Z ed d Z!dZ"de#d<z!ddlm Z m$Z$ddl%m&Z&e&Z'dZ(e(e'j)vsJdKddZ*Wne+ydKddZ*YnwddZ,dLdd Z-dMd"d#Z.dNd'd(Z/dOd,d-Z0Gd.d/d/Z1e1Z2ed0Z3dPd4d5Z4ed6Z5ed7Z6dQd>d?Z7zdd@l8m9Z9Wne+yGdAdBdBe:Z9Ynwere!j;Zs r5tuple[Any, list[Any]]cCs.t|}t|rt|^}}||fS|gfS)zStrip `Annotated` from the type if present. Returns: `(tp argument, ())` if not annotated, otherwise `(stripped type, annotations)`. )r r is_annotatedr )r0r4inner_tpargsr&r&r'unpack_annotatedKs   r:items list[str]strcCs2t|dkr |dSd|ddd|dS)z.Join with a comma and 'and' for the last item.rz, Nz, and )lenjoin)r;r&r&r' comma_andYs rBframetypes.FrameType | Nonedict[str, Any] | NonecCs8|dur|j}r|jddkrt|S|jSdSdS)zAttempt 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. N__name__typing)f_back f_globalsr!get_parent_namespacef_locals)rCbackr&r&r'rJbs rJc@seZdZdZdS)UnsetzUA singleton to represent an unset value. Copied from pydantic_ai/_utils.py. N)rF __module__ __qualname____doc__r&r&r&r'rMtsrMT t_or_unset T | Unset TypeIs[T]cCs|tuSr))UNSET)rRr&r&r'is_setsrV_P_RfuncCallable[_P, _R]r9_P.argskwargs _P.kwargscsL|rtdt|g|Ri|IdHStjd|g|RIdHSr))r*get_running_looprun_in_executorr)rYr9r\r&r&r'r_s(r_)LogfireNotConfiguredWarningc@s eZdZdS)r`N)rFrNrOr&r&r&r'r`sr`"Generator[LogfireSpan, None, None]c ost3tjdtdtj|i| }|VWdn1s#wYWddSWddS1s;wYdS)zCCreate a Logfire span without warning if logfire is not configured.ignore)categoryN)warningscatch_warningsfilterwarningsr`_logfirer)r9r\rr&r&r' logfire_spans "rhobjdepthintcCst}|dur dSt|D] }|j}|durdSq|jD] \}}||ur,|Sq |j|jkrE|jD] \}}||urD|Sq8dS)aUInfer 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)inspect currentframerangerHrKr;rI)rirj target_frame_nameitemr&r&r'infer_obj_names$  rs)rrrr)r0rrr1)r0rrr6)r;r<rr=)rCrDrrE)rRrSrrT)rYrZr9r[r\r]rrX)r9rr\rrra)rirrjrkrr)> __future__r _annotationsr*rltypesrdcollections.abcrr contextlibr functoolsrrGrrr r r r logfire_apir rtyping_extensionsrrtyping_inspectionrtyping_inspection.introspectionropentelemetry.tracerrgr__annotations__r,opentelemetry.trace.propagation.tracecontextrrr"fieldsr( ImportErrorr+r5r:rBrJrMrUrQrVrWrXr_logfire._internal.configr` UserWarningrrhrsr&r&r&r'sb