NgSV dZddlZddlZddlmZmZmZmZmZddl Z ddl m Z ddl m Z ddl m Z ddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl#m%Z%ddl#m&Z&ddl#m'Z'ddl#m(Z(ddl#m)Z)ddl#m*Z*dd l+m,Z,d!-e j.Z/ej0dd"krd#eej1fd$Z2nd#eej1fd%Z2d&e$d'ee j3fd(Z4Gd)d*Z5Gd+d,e5ej6Z6Gd-d.e5ej7Z7Gd/d0e5ej8Z8Gd1d2e5ej9Z9Gd3d4ej:Z: d;d5e;d6ee$d'ee j3d7eeefd8Z< d;d5e;d9e j=d6ee$d'ee j3d7eeef d:Z>dS)tjSN)asyncioTask all_tasksM/var/www/html/ai-engine/env/lib/python3.11/site-packages/grpc/aio/_channel.py _all_tasksr/7s|%%'''r-c(tjSr()r)r+r,r-r.r/r/<s """r- base_options compressionctj|}tjjt ff}t ||z|zSr()r create_channel_optionr ChannelArgKeyprimary_user_agent_string _USER_AGENTtuple)r1r2compression_channel_argumentuser_agent_channel_arguments r._augment_channel_argumentsr;@sW$0#E$$  :  # l & ' % &r-cReZdZUdZejed<ejed<e ed<e ed<e ed<e e eed<eeed<ejed<d ejd e d e d e d e e edeedejddfdZe dde ede ejdefdZdS)_BaseMultiCallablezrBase class of all multi callable objects. Handles the initialization logic and stores common attributes. _loop_channel_method_request_serializer_response_deserializer _interceptors _referenceschannelmethodrequest_serializerresponse_deserializer interceptors referencesloopr&Nch||_||_||_||_||_||_||_dSr()r>r?r@rArBrCrD)selfrErFrGrHrIrJrKs r.__init__z_BaseMultiCallable.__init__cs?   #5 &;#)%r-metadatar2c|p t}t|ts)t|trtj|}|rtt j||}|S)zBased on the provided values for or initialise the final metadata, as it should be used for the current call. )r isinstancer8 from_tupler augment_metadata)rOr2s r._init_metadataz!_BaseMultiCallable._init_metadatausn)xzz(H-- 5*Xu2M2M 5*844H  .xEEHr-)NN)__name__ __module__ __qualname____doc__r)AbstractEventLoop__annotations__r AioChannelbytesr#rrrrrrrN staticmethodrgrpc CompressionrrTr,r-r.r=r=Ss`  $$$$ NNN,,,,1111H%678888c  $$$$&"&&0 & 5 & x(9:; &I&'& &&&&$+/26<(d./ \r-r=ceZdZdddddddedeedeedeejdee deej d e j ee ffd ZdS) UnaryUnaryMultiCallableNtimeoutrO credentialswait_for_readyr2requestrcrOrdrer2r&c ,|||}|js?t|t|||||j|j|j|j|j }n7t|j||||||j|j|j|j|j }|Sr() rTrCrr$r?r@rArBr>rrMrfrcrOrdrer2calls r.__call__z UnaryUnaryMultiCallable.__call__s&&x==! !$W--  (+   DD-"  (+   D r-)rUrVrWr!rfloatrr^CallCredentialsboolr_r rr"rjr,r-r.raras$(+/6:)-26''''% ' <( ' d23 '!'d./'  "; #< =''''''r-raceZdZdddddddedeedeedeejdee deej d e j ee ffd ZdS) UnaryStreamMultiCallableNrbrfrcrOrdrer2r&c ,|||}|js?t|t|||||j|j|j|j|j }n7t|j||||||j|j|j|j|j }|Sr() rTrCrr$r?r@rArBr>rrhs r.rjz!UnaryStreamMultiCallable.__call__s&&x==! "$W--  (+   DD."  (+   D r-)rUrVrWr!rrkrr^rlrmr_r rr"rjr,r-r.roros$(+/6:)-26((((% ( <( ( d23 (!(d./(  #K$= >((((((r-roceZdZ d deedeedeedeejdee deej de j fd Z dS) StreamUnaryMultiCallableNrequest_iteratorrcrOrdrer2r&c ,|||}|js?t|t|||||j|j|j|j|j }n7t|j||||||j|j|j|j|j }|Sr() rTrCrr$r?r@rArBr>rrMrsrcrOrdrer2ris r.rjz!StreamUnaryMultiCallable.__call__s&&x==! " $W--  (+   DD."   (+   D r-NNNNNN)rUrVrWrr rkrr^rlrmr_r rrjr,r-r.rrrrs ;?#'+/6:)-26''"#67'%'<( ' d23 ' ! 'd./'  #''''''r-rrceZdZ d deedeedeedeejdee deej de j fd Z dS) StreamStreamMultiCallableNrsrcrOrdrer2r&c ,|||}|js?t|t|||||j|j|j|j|j }n7t|j||||||j|j|j|j|j }|Sr() rTrCrr$r?r@rArBr>rrus r.rjz"StreamStreamMultiCallable.__call__s&&x==! # $W--  (+   DD/"   (+   D r-rv)rUrVrWrr rkrr^rlrmr_r rrjr,r-r.rxrxs ;?#'+/6:)-26''"#67'%'<( ' d23 ' ! 'd./'  $''''''r-rxc eZdZUejed<ejed<ee ed<ee ed<ee ed<ee ed<de ded eejd eejd eeef d Zd ZdZdZd$deefdZdZ d%dedejfdZdejddfdZd&dZ de de!fdZ" d'de dee#dee$deede%f d Z& d'de dee#dee$deede'f d!Z( d'de dee#dee$deede)f d"Z* d'de dee#dee$deede+f d#Z,dS)(Channelr>r?_unary_unary_interceptors_unary_stream_interceptors_stream_unary_interceptors_stream_stream_interceptorstargetoptionsrdr2rIcg|_g|_g|_g|_|g|D]c}t |t r|j|3t |tr|j|ct |tr|j|t |tr|j|td |d t j zd tj zd tj zd tj ztj|_tjt#j|t'||||j|_dS)aConstructor. Args: target: The target to which to connect. options: Configuration options for the channel. credentials: A cygrpc.ChannelCredentials or None. compression: An optional value indicating the compression method to be used over the lifetime of the channel. interceptors: An optional list of interceptors that would be used for intercepting any RPC executed with that channel. NzInterceptor {} must be z{} or z{}. )r|r}r~rrQrappendrrr ValueErrorformatrUr get_working_loopr>r[rencoder;r?)rMrrrdr2rI interceptors r.rNzChannel.__init__Ds&*,&*,'*,'+-(  #+   k+FGG299+FFFF -IJJ 3::;GGGG -IJJ 3::;GGGG -JKK 4;;KHHHH$188EE"//*E*NOOP"//*F*OPPQ#//*F*OPPQ!--(E(NOO P,.. ) N6 " " &w < <  J    r-c K|Sr(r,rMs r. __aenter__zChannel.__aenter__ws  r-c@K|dd{VdSr(_close)rMexc_typeexc_valexc_tbs r. __aexit__zChannel.__aexit__zs0kk$r-cXK|jrdS|jt}g}g}|D] } |d}n)#t $r}dt |vrYd}~;d}~wwxYw|sG|d}|jd} | t| tj rt| dr| j|jurnrMrFrGrHrs r. unary_unaryzChannel.unary_unarys>' M N6 " "  !  * F J   r-c pt|jtj||||j|g|jSr()ror?rrr}r>rs r. unary_streamzChannel.unary_stream>( M N6 " "  !  + F J   r-c pt|jtj||||j|g|jSr()rrr?rrr~r>rs r. stream_unaryzChannel.stream_unaryrr-c pt|jtj||||j|g|jSr()rxr?rrrr>rs r. stream_streamzChannel.stream_stream(s>) M N6 " "  !  , F J   r-r()F)r&N)NNF)-rUrVrWr)rYrZr r[rrrrrrrrr^ChannelCredentialsr_rrrNrrrrkrrrmrrrrintrr#rrarrorrrrrxrr,r-r.r{r{<sk  $$$$#$?@@@@ $%A BBBB $%A BBBB!%&C!DDDD1 1 %1 d56 1 d./ 1 x(9:; 1 1 1 1 f   IIIV!!%!!!!&&& &+QQ"Q !QQQQ  !5      8888 # #    =AAE-2    %%89  ((=>  %TN  !     .=AAE-2    %%89  ((=>  %TN  "     .=AAE-2    %%89  ((=>  %TN  "     .=AAE-2    %%89  ((=>  %TN  #       r-r{rrrIc0t||dn|d||S)aCreates an insecure asynchronous Channel to a server. Args: target: The server address options: An optional list of key-value pairs (:term:`channel_arguments` in gRPC Core runtime) to configure the channel. compression: An optional value indicating the compression method to be used over the lifetime of the channel. interceptors: An optional sequence of interceptors that will be executed for any call executed with this channel. Returns: A Channel. Nr,)r{)rrr2rIs r.insecure_channelr:s-( o7    r-rdc:t||dn||j||S)a<Creates a secure asynchronous Channel to a server. Args: target: The server address. credentials: A ChannelCredentials instance. options: An optional list of key-value pairs (:term:`channel_arguments` in gRPC Core runtime) to configure the channel. compression: An optional value indicating the compression method to be used over the lifetime of the channel. interceptors: An optional sequence of interceptors that will be executed for any call executed with this channel. Returns: An aio.Channel. Nr,)r{ _credentials)rrdrr2rIs r.secure_channelrWs0, o7    r-)NNN)?rXr)systypingrrrrrr^rr r grpc._cythonr r r_callrrrr _interceptorrrrrrrrrr _metadatar_typingrrrr r!r"r#_utilsr$r __version__r7 version_infor*r/r_r;r=rarorrrxr{rrrrr,r-r.rs=< :::::::::::::: !!!!!!######""""""""""""!!!!!!++++++555555444444444444333333777777666666666666555555((((((******!!!!!!(((((( !!!!!!((((((((((((&--.>.JKK A(.((((( #.####%4+++\***** >***Z***** ?***Z{ { { { { m#{ { { @.2.2:>   ) *$*+8$567 @.2.2:>  () *$*+  8$567 r-