diff options
author | iximeow <me@iximeow.net> | 2023-07-02 01:01:39 -0700 |
---|---|---|
committer | iximeow <me@iximeow.net> | 2023-07-02 01:01:39 -0700 |
commit | 5da80c7631f07913f5d5568046089c91a0deb7d2 (patch) | |
tree | 8dfe5a48a411ac9610ceb6cd60277a33e661c44f /src/dbctx.rs | |
parent | f2366f4f95b0011aab517264e0ae84419abef660 (diff) |
clean up old stale jobs for clients that have gone away
Diffstat (limited to 'src/dbctx.rs')
-rw-r--r-- | src/dbctx.rs | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/src/dbctx.rs b/src/dbctx.rs index 0e999f3..3eb68bd 100644 --- a/src/dbctx.rs +++ b/src/dbctx.rs @@ -384,6 +384,17 @@ impl DbCtx { Ok(run_id) } + pub fn reap_task(&self, task_id: u64) -> Result<(), String> { + let conn = self.conn.lock().unwrap(); + + conn.execute( + "update runs set final_status=\"lost signal\", state=4 where id=?1;", + [task_id] + ).unwrap(); + + Ok(()) + } + pub fn metrics_for_run(&self, run: u64) -> Result<Vec<MetricRecord>, String> { let conn = self.conn.lock().unwrap(); |