mark tasks done!

This commit is contained in:
Brandon Thomas committed 2025-07-15 21:59:02 -04:00
1 parent a21e7b79db
commit e0132db4df
2 files changed
+13 -5

No files matched your search

@@ -125,10 +125,10 @@ async fn polling_loop(
TaskStatus::CompleteSuccess => continue,
_ => {} // Fall-through.
}
update_task_status(UpdateTaskArgs {
db: task_database.get_connection(),
task_id: task.id.clone(),
task_id: &task.id,
status: TaskStatus::CompleteSuccess,
}).await?;
@@ -1,3 +1,5 @@
use log::info;
use sqlx::Execute;
use crate::connection::TaskDbConnection;
use crate::error::SqliteTasksError;
use enums::tauri::tasks::task_status::TaskStatus;
@@ -5,7 +7,7 @@ use tokens::tokens::sqlite::tasks::TaskId;
pub struct UpdateTaskArgs<'a> {
pub db: &'a TaskDbConnection,
pub task_id: TaskId,
pub task_id: &'a TaskId,
pub status: TaskStatus,
}
@@ -17,17 +19,23 @@ pub async fn update_task_status(
let task_id_temp = args.task_id.as_str();
let status_temp = args.status.to_str();
info!("Update task id: {}, status: {}", task_id_temp, status_temp);
// TODO(bt,2025-07-15): We can't use a LIMIT without a certain compiler flag ?
let query = sqlx::query!(r#"
UPDATE tasks
SET task_status = ?
WHERE id = ?
"#,
task_id_temp,
status_temp,
task_id_temp,
);
let _r = query.execute(args.db.get_pool()).await?;
info!("query: {:?}", query.sql());
let res = query.execute(args.db.get_pool()).await?;
info!("Updated rows: {}", res.rows_affected());
Ok(())
}