(mode: str, source: str)
| 164 | |
| 165 | |
| 166 | def _start_selfcheck_background(mode: str, source: str) -> Dict[str, Any]: |
| 167 | run = create_selfcheck_run(mode=mode, source=source) |
| 168 | run_id = int(run["id"]) |
| 169 | task_id = _selfcheck_task_id(run_id) |
| 170 | task_manager.register_domain_task( |
| 171 | domain="selfcheck", |
| 172 | task_id=task_id, |
| 173 | task_type="selfcheck_run", |
| 174 | payload={"run_id": run_id, "mode": mode, "source": source}, |
| 175 | progress={"completed": 0, "total": 0}, |
| 176 | max_retries=3, |
| 177 | ) |
| 178 | _selfcheck_executor.submit(_run_selfcheck_async, run_id, mode, source, task_id) |
| 179 | return get_selfcheck_run(run_id) or run |
| 180 | |
| 181 | |
| 182 | @router.get("/runs") |
no test coverage detected