Handle 'worker' commands.
(self, args: list)
| 357 | raise ValueError(f"Unknown show target: {target}") |
| 358 | |
| 359 | def _handle_worker(self, args: list) -> dict: |
| 360 | """Handle 'worker' commands.""" |
| 361 | if not args: |
| 362 | raise ValueError("Missing worker action (add|remove|kill)") |
| 363 | |
| 364 | action = args[0].lower() |
| 365 | action_args = args[1:] |
| 366 | |
| 367 | if action == "add": |
| 368 | count = int(action_args[0]) if action_args else 1 |
| 369 | return self.handlers.worker_add(count) |
| 370 | elif action == "remove": |
| 371 | count = int(action_args[0]) if action_args else 1 |
| 372 | return self.handlers.worker_remove(count) |
| 373 | elif action == "kill": |
| 374 | if not action_args: |
| 375 | raise ValueError("Missing PID for worker kill") |
| 376 | pid = int(action_args[0]) |
| 377 | return self.handlers.worker_kill(pid) |
| 378 | else: |
| 379 | raise ValueError(f"Unknown worker action: {action}") |
| 380 | |
| 381 | def _handle_dirty(self, args: list) -> dict: |
| 382 | """Handle 'dirty' commands.""" |
no test coverage detected