U
    /eD                     @  s>   d dl mZ d dlZd dlmZ ejdedd d	ddZdS )
    )annotationsN)IOLoopz.the distributed.cli.utils module is deprecated   )
stacklevelc                   sP   ddl pt i  fdd}jjfD ]} |||< q6d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                   s.    fdd} |     d S )Nc                     s*   z d k	r I d H  W 5    X d S )N)stop )cleanuploopsigr   9/tmp/pip-unpacked-wheel-g426oqom/distributed/cli/utils.pycleanup_and_stop   s    zHinstall_signal_handlers.<locals>.handle_signal.<locals>.cleanup_and_stop)Zadd_callback_from_signalsignal)r
   framer   r   r	   Zold_handlersr   )r
   r   handle_signal   s    
z.install_signal_handlers.<locals>.handle_signal)r   r   currentSIGINTSIGTERM)r	   r   r   r
   r   r   r   install_signal_handlers   s    r   )NN)
__future__r   warningsZtornado.ioloopr   warnDeprecationWarningr   r   r   r   r   <module>   s     