(self, op, args=[])
| 123 | self.join() |
| 124 | |
| 125 | def request(self, op, args=[]): |
| 126 | req = _admin_request(op, args) |
| 127 | try: |
| 128 | self._main_pipe.send(req) |
| 129 | resp = self._main_pipe.recv() |
| 130 | if resp != True: |
| 131 | print("{} failed: {}".format(req, resp)) |
| 132 | raise resp |
| 133 | else: |
| 134 | print("{} succeeded".format(req)) |
| 135 | except Exception as e: |
| 136 | print("{} failed by exception: {}".format(req, e)) |
| 137 | raise |