| __init__(self, str|Path|None db_path=None) | aidge_in_space.jobs.JobStore | |
| _connect(self) | aidge_in_space.jobs.JobStore | protected |
| _init_schema(self) | aidge_in_space.jobs.JobStore | protected |
| _read(self) | aidge_in_space.jobs.JobStore | protected |
| _require(sqlite3.Connection con, int job_id) | aidge_in_space.jobs.JobStore | protectedstatic |
| _write(self) | aidge_in_space.jobs.JobStore | protected |
| cancel(self, int job_id) | aidge_in_space.jobs.JobStore | |
| cancel_requested(self, int job_id) | aidge_in_space.jobs.JobStore | |
| claim_next(self, str worker) | aidge_in_space.jobs.JobStore | |
| finish(self, int job_id, str status, str|None error=None) | aidge_in_space.jobs.JobStore | |
| get(self, int job_id) | aidge_in_space.jobs.JobStore | |
| heartbeat(self, int job_id) | aidge_in_space.jobs.JobStore | |
| job_dir(self, int job_id) | aidge_in_space.jobs.JobStore | |
| list_jobs(self, int|None limit=200, Iterable[str]|None statuses=None) | aidge_in_space.jobs.JobStore | |
| log_metrics(self, int job_id, int step, str kind, dict data) | aidge_in_space.jobs.JobStore | |
| metrics(self, int job_id, str|None kind=None) | aidge_in_space.jobs.JobStore | |
| path | aidge_in_space.jobs.JobStore | |
| recover_orphans(self, float stale_after_s=60.0) | aidge_in_space.jobs.JobStore | |
| requeue(self, int job_id) | aidge_in_space.jobs.JobStore | |
| reset_progress(self, int job_id, int step) | aidge_in_space.jobs.JobStore | |
| set_ckpt_path(self, int job_id, str path) | aidge_in_space.jobs.JobStore | |
| submit(self, dict config) | aidge_in_space.jobs.JobStore | |
| worker_alive(self, float max_age_s=30.0) | aidge_in_space.jobs.JobStore | |
| worker_heartbeat(self, str name, int|None job_id=None) | aidge_in_space.jobs.JobStore | |
1.15.0