(self, input: CommandInput)
| 139 | self.deleted_jobs = set() |
| 140 | |
| 141 | async def handle_command(self, input: CommandInput) -> CommandOutput: |
| 142 | cmd_type = self.adapter.parse_command_type(input) |
| 143 | if cmd_type == "submit": |
| 144 | return await self.handle_cli_submit(input) |
| 145 | elif cmd_type == "status": |
| 146 | return await self.handle_cli_status(input) |
| 147 | elif cmd_type == "delete": |
| 148 | return await self.handle_cli_delete(input) |
| 149 | raise Exception(f"Input command {input} not handled") |
| 150 | |
| 151 | async def handle_cli_submit(self, input: CommandInput) -> CommandOutput: |
| 152 | job_id = await self.handle_submit() |
no test coverage detected