
    0FieD                    T    d dl mZ d dlZd dlmZ  ej        ded           ddZdS )	    )annotationsN)IOLoopz.the distributed.cli.utils module is deprecated   )
stacklevelc                     ddl  pt          j                     i  fd}j        j        fD ]}                     ||          |<   dS )z
    Install global signal handlers to halt the Tornado IOLoop in case of
    a SIGINT or SIGTERM.  *cleanup* is an optional callback called,
    before the loop stops, with a single signal number argument.
    r   Nc                z      fd}                     |                                                     d S )Nc                    K   	               d {V                                    d S #                                   w xY w)N)stop)cleanuploopsigs   5lib/python3.11/site-packages/distributed/cli/utils.pycleanup_and_stopzHinstall_signal_handlers.<locals>.handle_signal.<locals>.cleanup_and_stop   sU      &!'#,,&&&&&&&				s	   . A)add_callback_from_signalsignal)r   framer   r   r   old_handlersr   s   `  r   handle_signalz.install_signal_handlers.<locals>.handle_signal   s_    	 	 	 	 	 	 	 	%%&6777 	c<,-----    )r   r   currentSIGINTSIGTERM)r   r   r   r   r   r   s   ``  @@r   install_signal_handlersr      s     MMM#6>##DL. . . . . . . . v~. > >"MM#}==S> >r   )NN)
__future__r   warningstornado.ioloopr   warnDeprecationWarningr    r   r   <module>r       st    " " " " " "  ! ! ! ! ! ! 46HUV   
> > > > > >r   