j 8ddlZddlZddlmZmZmZmZmZmZm Z ddl Z ddl Z ddl Z ddlmZmZddlZej$eZdZeZdZdZdZdZdZd eed eed ed ed e j<f dZd eed eed eeeffdZ Gdde j<Z!y)N)OptionalDictAnyUnionIterable AsyncIterableMapping)hookspackage_versionzX-Opik-Deprecation d workspaceapi_keycheck_tls_certificatecompress_json_requestsreturnctjt}|dur%dtjvrtjdn|}tjj d}tj tttt}|||d|d}tjj|}td d|i|} t||} | j j#| tjj%| | S) N)keepalive_expiryT SSL_CERT_FILE_OPIK_HTTP_PROXY)connectreadwritepool)limitsverifytimeoutfollow_redirectsproxyr)rr)httpxLimitsKEEPALIVE_EXPIRY_SECONDSosenvirongetTimeoutCONNECT_TIMEOUT_SECONDSREAD_TIMEOUT_SECONDSWRITE_TIMEOUT_SECONDSPOOL_TIMEOUT_SECONDSr httpx_client_hookbuild_init_argumentsOpikHttpxClient_prepare_headersheadersupdateapply_httpx_client_hooks) rrrrrrr!rkwargsclientr2s j/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/httpx_client.pyr(r(s \\+C DF !D (_ -J ?# " JJNN- .Emm' !# ! G  F $ $ 9 9& AF  U4J Uf UFGDG NN'" 44V< Mcntjtjdd}|||d<|||d<|S)Ngzip)zX-OPIK-DEBUG-SDK-VERSIONzX-OPIK-DEBUG-PY-VERSIONzAccept-EncodingzComet-Workspace Authorization)r VERSIONplatformpython_version)rrresults r7r1r1DsK%4$;$;#+#:#:#<!F $- !") Mr8c6eZdZddededdffd Zdddddddejdd dede ejefd e e ee e e ee fd e eeefd ed ed edededededej ffdZdej dedej$ffd ZxZS)r0rr5rNc @t|di|||_i|_y)Nr")super__init__rwarnings)selfrr5 __class__s r7rCzOpikHttpxClient.__init__Ws" "6"&<#)+ r8) contentdatafilesjsonparamsr2cookiesr extensionsmethodurlrGrHrIrJrKr2rLrrMc $|jrj|dvrf|dtj|jd} t j | }d}|i}t t||d<d|d<d|vrd|d<t |%||||||||| | | S) N)POSTPUTPATCHzutf-8zContent-Lengthr:zContent-Encodingz content-typezapplication/json;charset=utf-8z Content-Type) rNrOrGrHrIrJrKr2rLrrM) rjsonlibdumpsencoder:compressstrlenrB build_request)rErNrOrGrHrIrJrKr2rLrrM json_datarFs r7rZzOpikHttpxClient.build_request\s&  & &11d6F#MM$/66w? -- 2? G,/G ,=().4*+!0.NGN+w$!%  r8requestc Jt||fi|}|jjt}|rpd}|j d|j j}||jvr;d|j|<tj||j |j ||S)Nz!Deprecation warning for %s %s: %s:T) rBsendr2r(DEPRECATION_HEADERrNrOpathrDLOGGERwarning)rEr\r5responsedeprecation_messagemessage request_keyrFs r7r_zOpikHttpxClient.sends7<262&..223EF 9G$^^,Agkk.>.>-?@K$--/-1 k*W^^W[[:Mr8)T)__name__ __module__ __qualname__boolrrCr#USE_CLIENT_DEFAULTrXrURLrbytesrrr RequestrZResponser_ __classcell__)rFs@r7r0r0Vs!,t,c,d, ,0//, , 599c> ",  #uhuo}U/CC D , wsCx(), , , , , , , , !, \ EMM S U^^  r8r0)"r:loggingtypingrrrrrrr r#r&rJrTr r r= getLoggerrhrbr`rX CABundlePathr%r*r+r,r-rkClientr(r1r0r"r8r7rxs OOO $   8 $) (}( c]( (! (  \\ (V}'/} #s(^$@ell@r8