(self)
| 153 | return self.adapter.format_submit_output(job_id) |
| 154 | |
| 155 | async def handle_submit(self) -> JobId: |
| 156 | # By default, create a new job |
| 157 | job_id = default_job_id(self.job_counter) |
| 158 | self.job_counter += 1 |
| 159 | |
| 160 | # The state of this job could already have been set before manually |
| 161 | if job_id not in self.jobs: |
| 162 | self.jobs[job_id] = JobData.queued() |
| 163 | return job_id |
| 164 | |
| 165 | async def handle_cli_status(self, input: CommandInput) -> CommandOutput: |
| 166 | job_ids = self.adapter.parse_status_job_ids(input) |
no test coverage detected