diff --git a/crates/lib/database_queries/src/api_tokens/delete_api_token.rs b/crates/lib/database_queries/src/api_tokens/delete_api_token.rs index dc1e2d00de..7345fbcc0d 100644 --- a/crates/lib/database_queries/src/api_tokens/delete_api_token.rs +++ b/crates/lib/database_queries/src/api_tokens/delete_api_token.rs @@ -31,6 +31,6 @@ LIMIT 1 Err(err) => { Err(anyhow!("error with query: {:?}", err)) }, - Ok(results) => Ok(true), + Ok(_r) => Ok(true), } } diff --git a/crates/lib/database_queries/src/api_tokens/edit_api_token.rs b/crates/lib/database_queries/src/api_tokens/edit_api_token.rs index 9dd62164e8..0d4a668900 100644 --- a/crates/lib/database_queries/src/api_tokens/edit_api_token.rs +++ b/crates/lib/database_queries/src/api_tokens/edit_api_token.rs @@ -35,6 +35,6 @@ LIMIT 1 Err(err) => { Err(anyhow!("error with query: {:?}", err)) }, - Ok(results) => Ok(true), + Ok(_r) => Ok(true), } } diff --git a/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_done.rs b/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_done.rs index 5acb43700d..6d94cf3ff6 100644 --- a/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_done.rs +++ b/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_done.rs @@ -1,3 +1,4 @@ +use anyhow::anyhow; use container_common::anyhow_result::AnyhowResult; use crate::tts::tts_inference_jobs::_keys::TtsInferenceJobId; use sqlx::MySqlPool; @@ -26,8 +27,13 @@ WHERE id = ? job_id.0 ) .execute(pool) - .await?; + .await; - Ok(()) + match query_result { + Err(err) => { + Err(anyhow!("error with query: {:?}", err)) + }, + Ok(_r) => Ok(()), + } } diff --git a/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_failure.rs b/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_failure.rs index 19824707be..3bb8a93143 100644 --- a/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_failure.rs +++ b/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_failure.rs @@ -1,3 +1,4 @@ +use anyhow::anyhow; use container_common::anyhow_result::AnyhowResult; use crate::tts::tts_inference_jobs::list_available_tts_inference_jobs::AvailableTtsInferenceJob; use sqlx::MySqlPool; @@ -35,7 +36,12 @@ WHERE id = ? job.id.0, ) .execute(pool) - .await?; + .await; - Ok(()) + match query_result { + Err(err) => { + Err(anyhow!("error with query: {:?}", err)) + }, + Ok(_r) => Ok(()), + } } diff --git a/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_permanently_dead.rs b/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_permanently_dead.rs index e1441afb38..58c605d9c5 100644 --- a/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_permanently_dead.rs +++ b/crates/lib/database_queries/src/tts/tts_inference_jobs/mark_tts_inference_job_permanently_dead.rs @@ -1,3 +1,4 @@ +use anyhow::anyhow; use container_common::anyhow_result::AnyhowResult; use crate::tts::tts_inference_jobs::_keys::TtsInferenceJobId; use sqlx::MySqlPool; @@ -22,7 +23,12 @@ WHERE id = ? job_id.0, ) .execute(pool) - .await?; + .await; - Ok(()) + match query_result { + Err(err) => { + Err(anyhow!("error with query: {:?}", err)) + }, + Ok(_r) => Ok(()), + } } diff --git a/crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs b/crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs index 18e890424c..966624552e 100644 --- a/crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs +++ b/crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs @@ -28,6 +28,6 @@ LIMIT 1 Err(err) => { Err(anyhow!("error with query: {:?}", err)) }, - Ok(results) => Ok(true), + Ok(_r) => Ok(true), } } diff --git a/crates/lib/database_queries/src/twitch_oauth/find.rs b/crates/lib/database_queries/src/twitch_oauth/find.rs index debe662551..453c674b23 100644 --- a/crates/lib/database_queries/src/twitch_oauth/find.rs +++ b/crates/lib/database_queries/src/twitch_oauth/find.rs @@ -203,7 +203,7 @@ LEFT OUTER JOIN users let mut query = "".to_string(); let mut first_predicate_added = false; - if let Some(user_token) = self.scope_user_token.as_deref() { + if let Some(_user_token) = self.scope_user_token.as_deref() { if !first_predicate_added { query.push_str(" WHERE users.token = ?"); first_predicate_added = true; @@ -212,7 +212,7 @@ LEFT OUTER JOIN users } } - if let Some(user_id) = self.scope_twitch_user_id { + if let Some(_user_id) = self.scope_twitch_user_id { if !first_predicate_added { query.push_str(" WHERE twitch_oauth_tokens.twitch_user_id = ?"); first_predicate_added = true; @@ -221,7 +221,7 @@ LEFT OUTER JOIN users } } - if let Some(username) = self.scope_twitch_username_lowercase.as_deref() { + if let Some(_username) = self.scope_twitch_username_lowercase.as_deref() { if !first_predicate_added { query.push_str(" WHERE twitch_oauth_tokens.twitch_username_lowercase = ?"); first_predicate_added = true;