Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(2)  |  Call(2)  |  Derive(0)  |  Import(0)
Get watcher from the arbiter if any.

src/c/i/circus-0.10.0/circus/commands/decrproc.py   circus(Download)
    def execute(self, arbiter, props):
        watcher = self._get_watcher(arbiter, props.get('name'))
        nb = props.get('nb', 1)
        resp = TransformableFuture()
        resp.set_upstream_future(watcher.decr(nb))

src/c/i/circus-HEAD/circus/commands/decrproc.py   circus(Download)
    def execute(self, arbiter, props):
        watcher = self._get_watcher(arbiter, props.get('name'))
        nb = props.get('nb', 1)
        resp = TransformableFuture()
        resp.set_upstream_future(watcher.decr(nb))