(self)
| 57 | raise RuntimeError(f"VM Error: {resp.get('error')}") |
| 58 | |
| 59 | def stop(self): |
| 60 | if self.process: |
| 61 | try: |
| 62 | self.process.stdin.write(json.dumps({"cmd": "stop"}) + "\n") |
| 63 | self.process.stdin.flush() |
| 64 | self.process.wait(timeout=2) |
| 65 | except: |
| 66 | self.process.kill() |
| 67 | self.process = None |
| 68 | |
| 69 | def run_agent(): |
| 70 | vm = AgentVMClient() |