diff --git a/crates/service/storyteller_web/src/tts_inference_job.rs b/crates/service/storyteller_web/src/tts_inference_job.rs index c089de5cb7..a25222a357 100644 --- a/crates/service/storyteller_web/src/tts_inference_job.rs +++ b/crates/service/storyteller_web/src/tts_inference_job.rs @@ -305,6 +305,8 @@ async fn main() -> AnyhowResult<()> { }) .transpose()?; + info!("Using 'MAYBE_MINIMUM_PRIORITY' of {:?}", maybe_minimum_priority); + let inferencer = Inferencer { download_temp_directory: temp_directory, mysql_pool, @@ -389,7 +391,7 @@ async fn main_loop(inferencer: Inferencer) { }; if jobs.is_empty() { - noop_logger.log_after_awhile(); + noop_logger.log_message_after_awhile("No TTS jobs picked up from database!"); std::thread::sleep(Duration::from_millis(inferencer.job_batch_wait_millis)); continue; diff --git a/crates/service/storyteller_web/src/util/noop_logger.rs b/crates/service/storyteller_web/src/util/noop_logger.rs index 17dcc1da93..bd789c7a46 100644 --- a/crates/service/storyteller_web/src/util/noop_logger.rs +++ b/crates/service/storyteller_web/src/util/noop_logger.rs @@ -29,4 +29,17 @@ impl NoOpLogger { self.op_count += 1; } + + pub fn log_message_after_awhile(&mut self, message: &str) { + let now = Utc::now(); + let delta = now - self.last_log_time; + + if delta > self.logless_duration { + info!("No operations for {:?}. {} operations: {}", delta, self.op_count, message); + self.op_count = 0; + self.last_log_time = now; + } + + self.op_count += 1; + } } \ No newline at end of file