uPj lUdZddlmZddlmZddlmZddlmZm Z m Z ddl Z ddl m Z Gdd e ZGd d e ZGd d ZeZded<edGddZeZded<eed ddZddZddZ ddZ ddZy) zBThin Python wrapper for the native Rust Anthropic Messages bridge.) annotations) Awaitable) dataclass)FinalProtocolcastN)timeout_to_secondsc4eZdZ ddZy) RustMessagesctNNotImplementedErrorselfmodelbodyapi_keyapi_basecustom_llm_provider extra_headerstimeout_secondss a/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/rust_bridge/messages.py__call__zRustMessages.__call__ "!N)rstrrdict[str, object]r str | Nonerrrrrdict[str, object] | Noner float | Nonereturnr__name__ __module__ __qualname__rrrr r sU " "  " "  " ( "0 "& "  "rr c4eZdZ ddZy) RustAmessagesctr rrs rrzRustAmessages.__call__rrN)rrrrrrrrrrrr rr!r"zAwaitable[dict[str, object]]r#r'rrr)r)sU " "  " "  " ( "0 "& " & "rr)c eZdZy)_UnsetN)r$r%r&r'rrr,r,*srr,z Final[_Unset]_UNSETT)slotsc*eZdZUdZded<dZded<y)_RustMessagesStateNRustMessages | NonemessagesRustAmessages | None amessages)r$r%r&r2__annotations__r4r'rrr0r01s$(H!(&*I#*rr0zFinal[_RustMessagesState]_STATEr2r4crt|ts |t_t|ts |t_yyr ) isinstancer,r6r2r4r7s rset_rust_messagesr::s, h '" i ($ )rctjtjSddlm}|}|yt t t |ddS)Nrget_native_bridger2)r6r2litellm.rust_bridger=rr getattrr= native_bridges rload_rust_messagesrBEs@ "5,.M  gmZF GGrctjtjSddlm}|}|yt t t |ddS)Nrr<r4)r6r4r>r=rr)r?r@s rload_rust_amessagesrDPsD #5,.M  w}k4H IIrc Lt}|y|||||||t|SN)rrrrrrr)rBr )rrrrrrtimeout rust_messagess rr2r2[s<./M  /#*73 rc hKt}|y|||||||t|d{S7wrF)rDr )rrrrrrrGrust_amessagess rr4r4ssJ01N /#*73  s )202)r2zRustMessages | None | _Unsetr4zRustAmessages | None | _Unsetr"None)r"r1)r"r3)rrrrrrrrrrrr rGzfloat | httpx.Timeout | Noner"r )__doc__ __future__rcollections.abcr dataclassesrtypingrrrhttpxlitellm.rust_bridge.timeoutsr r r)r,r-r5r0r6r:rBrDr2r4r'rrrSsVH"%!(( ; "8 " "H "    +++ %7$8!8 .4/5%*%-% %HJ      $ ,*0      $ ,*r