mutual exclusion seems to work well!

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);
   }
 

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));
   }
 }