From 5da80c7631f07913f5d5568046089c91a0deb7d2 Mon Sep 17 00:00:00 2001 From: iximeow Date: Sun, 2 Jul 2023 01:01:39 -0700 Subject: clean up old stale jobs for clients that have gone away --- src/dbctx.rs | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'src/dbctx.rs') 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, String> { let conn = self.conn.lock().unwrap(); -- cgit v1.1