

@util.synchronized('watcher_incr')
@gen.coroutine
@util.debuglog
def incr(self, nb=1):
    res = (yield self.set_numprocesses((self.numprocesses + nb)))
    raise gen.Return(res)

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