Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
0.1.2 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
asgiref
/
__pycache__
/
server.cpython-311.pyc
|
|---|
§
Ögu ã ól d dl Z d dlZd dlZd dlZddlmZ ej e¦ « Z G d d¦ « Z dS )é Né )Úguarantee_single_callablec óN e Zd ZdZdZddZd Zd Zd Zd Z d Z
d
Z d Z d Z
d
S )ÚStatelessServerax
Base server class that handles basic concepts like application instance
creation/pooling, exception handling, and similar, for stateless protocols
(i.e. ones without actual incoming connections to the process)
Your code should override the handle() method, doing whatever it needs to,
and calling get_or_create_application_instance with a unique `scope_id`
and `scope` for the scope it wants to get.
If an application instance is found with the same `scope_id`, you are
given its input queue, otherwise one is made for you with the scope provided
and you are given that fresh new input queue. Either way, you should do
something like:
input_queue = self.get_or_create_application_instance(
"user-123456",
{"type": "testprotocol", "user_id": "123456", "username": "andrew"},
)
input_queue.put_nowait(message)
If you try and create an application instance and there are already
`max_application` instances, the oldest/least recently used one will be
reclaimed and shut down to make space.
Application coroutines that error will be found periodically (every 100ms
by default) and have their exceptions printed to the console. Override
application_exception() if you want to do more when this happens.
If you override run(), make sure you handle things like launching the
application checker.
g¹?éè c ó0 || _ || _ i | _ d S ©N)Ú applicationÚmax_applicationsÚapplication_instances)Úselfr
r s ú5/tmp/pip-target-6culloxw/lib/python/asgiref/server.pyÚ__init__zStatelessServer.__init__. s à&ÔØ 0Ô à%'Ô"Ð"Ð"ó c ó t j ¦ « }t j | ¦ « ¦ « | | ¦ « ¦ « dS # t $ r t d¦ « Y dS w xY w)zD
Runs the asyncio event loop with our handler loop.
z Exiting due to Ctrl-C/interruptN) ÚasyncioÚget_event_loopÚ
ensure_futureÚapplication_checkerÚrun_until_completeÚhandleÚKeyboardInterruptÚloggerÚinfo)r
Ú
event_loops r ÚrunzStatelessServer.run7 s õ Ô+Ñ-Ô-
ÝÔ d× 6Ò 6Ñ 8Ô 8Ñ9Ô9Ð9ð ;Ø × )Ò )¨$¯+ª+©-¬-Ñ 8Ô 8Ð 8Ð 8Ð 8øÝ ð ;ð ;ð ;Ý KKÐ9Ñ :Ô :Ð :Ð :Ð :Ð :ð ;øøøs »'A$ Á$$B Â B c ó$ K t d¦ « )NzYou must implement handle()©ÚNotImplementedError)r
s r r zStatelessServer.handleB s è è Ý!Ð"?Ñ@Ô@Ð@r c ó$ K t d¦ « )zM
Receives outbound sends from applications and handles them.
z%You must implement application_send()r )r
ÚscopeÚmessages r Úapplication_sendz StatelessServer.application_sendE s è è õ "Ð"IÑJÔJÐJr c ó | j v r4t j ¦ « j | d< j | d S t j ¦ « j k r1 ¦ « t j ¦ « j k °1t j ¦ « }t j ¦ « }t j ||j
fd¬¦ « ¦ « }||t j ¦ « d j |< |S )zH
Creates an application instance and returns its queue.
Ú last_usedÚ input_queuec ó0 | ¦ « S r )r# )r" r! r
s r ú<lambda>zDStatelessServer.get_or_create_application_instance.<locals>.<lambda>_ s ø T×%:Ò%:¸5À'Ñ%JÔ%J r )r! ÚreceiveÚsend)r& Úfuturer! r% ) r ÚtimeÚlenr Ú"delete_oldest_application_instancer ÚQueuer r
r Úget)r
Úscope_idr! r& Úapplication_instancer+ s ` ` r Ú"get_or_create_application_instancez2StatelessServer.get_or_create_application_instanceM s øø ð tÔ1Ð 1Ð 1Ý@DÄ Á Ä DÔ & xÔ 0°Ñ =ØÔ-¨hÔ7¸
ÔFÐ Få$Ô,Ñ-Ô-°Ô0EÒEÐEØ × 3Ò 3Ñ 5Ô 5Ð 5õ $Ô,Ñ-Ô-°Ô0EÒEÐEõ moo Ý 8¸Ô9IÑ JÔ JÐ åÔ&Ø Ð ØØ#ØJÐJÐJÐJÐJð
ñ
ô
ñ
ô
ð 'Ø ØÝ ð 0
ð 0
Ô" 8Ñ,ð Ðr c óì t d | j ¦ « D ¦ « ¦ « }| j ¦ « D ])\ }}|d |k r| |¦ « dS *dS )zC
Finds and deletes the oldest application instance
c 3 ó& K | ] }|d V
dS )r% N© )Ú.0Údetailss r ú <genexpr>zEStatelessServer.delete_oldest_application_instance.<locals>.<genexpr>n s8 è è ð
ð
Ø%,GKÔ ð
ð
ð
ð
ð
ð
r r% N)Úminr ÚvaluesÚitemsÚdelete_application_instance)r
Ú oldest_timer1 r8 s r r. z2StatelessServer.delete_oldest_application_instancej s õ ð
ð
Ø04Ô0J×0QÒ0QÑ0SÔ0Sð
ñ
ô
ñ
ô
ð "&Ô!;×!AÒ!AÑ!CÔ!Cð ð Ñ HgØ{Ô# {Ò2Ð2Ø×0Ò0°Ñ:Ô:Ð:ð ð 3ð ð r c ó | j | }| j |= |d ¦ « s |d ¦ « dS dS )z
Removes an application instance (makes sure its task is stopped,
then removes it from the current set)
r+ N)r ÚdoneÚcancel)r
r1 r8 s r r= z+StatelessServer.delete_application_instancex s\ ð
Ô,¨XÔ6Ø Ô & xÐ 0ØxÔ ×%Ò%Ñ'Ô'ð 'Ø HÔ × $Ò $Ñ &Ô &Ð &Ð &Ð &ð 'ð 'r c óx K t j | j ¦ « d{V t | j ¦ « ¦ « D ]q\ }}|d ¦ « rR|d ¦ « }|r | ||¦ « d{V | j |= a# t $ r Y mw xY wr¸)z
Goes through the set of current application instance Futures and cleans up
any that are done/prints exceptions for any that errored.
TNr+ )
r ÚsleepÚ application_checker_intervalÚlistr r< r@ Ú exceptionÚapplication_exceptionÚKeyError)r
r1 r8 rF s r r z#StatelessServer.application_checker sø è è ð
Ý- Ô AÑBÔBÐ BÐ BÐ BÐ BÐ BÐ BÐ BÝ%)¨$Ô*D×*JÒ*JÑ*LÔ*LÑ%MÔ%Mð
ð
Ñ!'Ø8Ô$×)Ò)Ñ+Ô+ð Ø '¨Ô 1× ;Ò ;Ñ =Ô =IØ ð MØ "× 8Ò 8¸ÀGÑ LÔ LÐLÐLÐLÐLÐLÐLÐLð Ø Ô 6°xÐ @Ð @øÝ#ð ð ð à ð øøøð
ð s Â!B*Â*
B7Â6B7c ó K t j d|d t j |j ¦ « ¦ « d| ¦ « dS )zL
Called whenever an application coroutine has an exception.
z%Exception inside application: %s
%s%sÚ z N)ÚloggingÚerrorÚjoinÚ tracebackÚ format_tbÚ
__traceback__)r
rF Úapplication_detailss r rG z%StatelessServer.application_exception sT è è õ
Ø 4Ø Ø GGIÔ'¨ Ô(?Ñ@Ô@Ñ AÔ AØ Ð Ð ñ
ô
ð
ð
ð
r N)r )Ú__name__Ú
__module__Ú __qualname__Ú__doc__rD r r r r# r3 r. r= r rG r6 r r r r s¹ ð ð ð@ $'Ð ð(ð (ð (ð (ð ;ð ;ð ;ðAð Að AðKð Kð Kðð ð ð: ð ð ð 'ð 'ð 'ð ð ð ð$
ð
ð
ð
ð
r r )
r rK r, rN Ú
compatibilityr Ú getLoggerrR r r r6 r r ú<module>rX s ðØ Ø Ø Ø Ð Ð Ð à 4Ð 4Ð 4Ð 4Ð 4Ð 4à Ô 8Ñ $Ô $ðR
ð R
ð R
ð R
ð R
ñ R
ô R
ð R
ð R
ð R
r