Save work before fetching queue
This commit is contained in:
parent
416e3e6aa1
commit
22efa5bfc9
1 changed files with 5 additions and 5 deletions
|
|
@ -28,7 +28,7 @@ use crate::{
|
|||
somehow,
|
||||
};
|
||||
|
||||
async fn save_work(run: FinishedRun, db: SqlitePool) -> somehow::Result<()> {
|
||||
async fn save_work(run: FinishedRun, db: &SqlitePool) -> somehow::Result<()> {
|
||||
let mut tx = db.begin().await?;
|
||||
let conn = tx.acquire().await?;
|
||||
|
||||
|
|
@ -120,6 +120,10 @@ async fn post_status(
|
|||
Err(response) => return Ok(response),
|
||||
};
|
||||
|
||||
if let Some(run) = request.submit_work {
|
||||
save_work(run, &db).await?;
|
||||
}
|
||||
|
||||
// Fetch queue
|
||||
let queue = sqlx::query_scalar!(
|
||||
"\
|
||||
|
|
@ -157,10 +161,6 @@ async fn post_status(
|
|||
(work, abort_work)
|
||||
};
|
||||
|
||||
if let Some(run) = request.submit_work {
|
||||
save_work(run, db).await?;
|
||||
}
|
||||
|
||||
debug!("Received status update from {name}");
|
||||
Ok(Json(ServerResponse { work, abort_work }).into_response())
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue