| 381 | first_job = default_job_id() |
| 382 | |
| 383 | class FailingStatusManager(CommandHandler): |
| 384 | async def handle_status(self, job_ids: List[JobId]) -> Dict[JobId, JobData]: |
| 385 | if first_job in job_ids: |
| 386 | raise ManagerException("Failed to get allocation status") |
| 387 | return await super().handle_status(job_ids) |
| 388 | |
| 389 | with MockJobManager(hq_env, FailingStatusManager(flavor.create_adapter())): |
| 390 | start_server_with_quick_refresh(hq_env) |
no outgoing calls