diff --git a/src/job_queries/tts_inference_job_queries.rs b/src/job_queries/tts_inference_job_queries.rs index 9d1450facd..7025efc721 100644 --- a/src/job_queries/tts_inference_job_queries.rs +++ b/src/job_queries/tts_inference_job_queries.rs @@ -138,6 +138,8 @@ FOR UPDATE info!("Can acquire lock??? {}", can_transact); if !can_transact { + info!("returning"); + transaction.rollback().await?; return Ok(false); } diff --git a/src/tts_inference_job.rs b/src/tts_inference_job.rs index f538d09ef1..961dbb7215 100644 --- a/src/tts_inference_job.rs +++ b/src/tts_inference_job.rs @@ -223,7 +223,7 @@ async fn main_loop(inferencer: Inferencer) { if jobs.is_empty() { info!("No jobs!"); - std::thread::sleep(Duration::from_millis(1500)); + std::thread::sleep(Duration::from_millis(20)); continue; } @@ -241,7 +241,7 @@ async fn main_loop(inferencer: Inferencer) { timeout_millis = START_TIMEOUT_MILLIS; // reset - std::thread::sleep(Duration::from_millis(500)); + std::thread::sleep(Duration::from_millis(20)); } }