

@gen.coroutine
@util.debuglog
def kill_processes(self, stop_signal=None, graceful_timeout=None):
    'Kill all processes (stop_signal, graceful_timeout then SIGKILL)\n        '
    active_processes = self.get_active_processes()
    try:
        (yield [self.kill_process(process, stop_signal=stop_signal, graceful_timeout=graceful_timeout) for process in active_processes])
    except OSError as e:
        if (e.errno != errno.ESRCH):
            raise

dataset/ETHPy150Open circus-tent/circus/circus/watcher.py Watcher.kill_processes/original