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

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

src/c/i/circus-0.10.0/circus/commands/status.py   circus(Download)
    def execute(self, arbiter, props):
        if 'name' in props:
            watcher = self._get_watcher(arbiter, props['name'])
            return {"status": watcher.status()}
        else:

src/c/i/circus-0.10.0/circus/commands/numprocesses.py   circus(Download)
    def execute(self, arbiter, props):
        if 'name' in props:
            watcher = self._get_watcher(arbiter, props['name'])
            return {
                "numprocesses": len(watcher),

src/c/i/circus-0.10.0/circus/commands/list.py   circus(Download)
    def execute(self, arbiter, props):
        if 'name' in props:
            watcher = self._get_watcher(arbiter, props['name'])
            processes = watcher.get_active_processes()
            status = [(p.pid, p.status) for p in processes]

src/c/i/circus-HEAD/circus/commands/status.py   circus(Download)
    def execute(self, arbiter, props):
        if 'name' in props:
            watcher = self._get_watcher(arbiter, props['name'])
            return {"status": watcher.status()}
        else:

src/c/i/circus-HEAD/circus/commands/numprocesses.py   circus(Download)
    def execute(self, arbiter, props):
        if 'name' in props:
            watcher = self._get_watcher(arbiter, props['name'])
            return {
                "numprocesses": len(watcher),

src/c/i/circus-HEAD/circus/commands/list.py   circus(Download)
    def execute(self, arbiter, props):
        if 'name' in props:
            watcher = self._get_watcher(arbiter, props['name'])
            processes = watcher.get_active_processes()
            status = [(p.pid, p.status) for p in processes]

src/c/i/circus-0.10.0/circus/commands/options.py   circus(Download)
    def execute(self, arbiter, props):
        watcher = self._get_watcher(arbiter, props['name'])
        return {"options": dict(watcher.options())}
 
    def console_msg(self, msg):

src/c/i/circus-0.10.0/circus/commands/incrproc.py   circus(Download)
    def execute(self, arbiter, props):
        watcher = self._get_watcher(arbiter, props.get('name'))
        if watcher.singleton:
            return {"numprocesses": watcher.numprocesses, "singleton": True}
        else:

src/c/i/circus-0.10.0/circus/commands/get.py   circus(Download)
    def execute(self, arbiter, props):
        watcher = self._get_watcher(arbiter, props.get('name'))
 
        # get options values. It return an error if one of the asked
        # options isn't found

src/c/i/circus-HEAD/circus/commands/options.py   circus(Download)
    def execute(self, arbiter, props):
        watcher = self._get_watcher(arbiter, props['name'])
        return {"options": dict(watcher.options())}
 
    def console_msg(self, msg):

  1 | 2 | 3  Next