

@util.synchronized('watcher_do_action')
@gen.coroutine
def do_action(self, num):
    if (num == 0):
        (yield self.manage_processes())
    elif (not self.is_stopped()):
        (yield self._reload())

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