
    0Fie-                    ^    d dl mZ d dlZd dlZd dlZd dlmZ  ej        e          Z	ddZ
dS )    )annotationsN)Anyreturnintc                   K   t           j        t           j        f} t          j                    t          j                    i dfd}| D ]}t          j         ||          |<   	                                  d{V  sJ t                              dt          j	                  j
                   | D ]}t          j         ||                    S # | D ]}t          j         ||                    w xY w)z<Wait for sigint or sigterm by setting global signal handlersNc                v    | t          j         | |                                         j                   d S )N)signalcall_soon_threadsafeset)signumframecaught_signaleventloopold_handlerss     4lib/python3.11/site-packages/distributed/_signals.pyhandle_signalz'wait_for_signals.<locals>.handle_signal   s?      	fl62333!!%),,,,,    zReceived signal %s (%d))r	   SIGINTSIGTERMasyncioget_running_loopEventwaitloggerinfoSignalsname)signalsr   sigr   r   r   r   s      @@@@r   wait_for_signalsr!      sL     }fn-G#%%DMOOE#%L $M- - - - - - - -  > >"M#}==S	2jjll%v~m'D'D'I=	
 	
 	
  	2 	2CM#|C01111	27 	2 	2CM#|C01111	2s   /AC" ""D)r   r   )
__future__r   r   loggingr	   typingr   	getLogger__name__r   r!    r   r   <module>r(      st    " " " " " "         		8	$	$2 2 2 2 2 2r   