From 831355879505b61b4b5e53ea5eb608dacdb89710 Mon Sep 17 00:00:00 2001 From: Brandon Thomas Date: Mon, 13 Oct 2025 11:03:50 -0400 Subject: [PATCH] debugging for inference-job loop --- .../job/inference_job/src/job/job_loop/main_loop.rs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/crates/service/job/inference_job/src/job/job_loop/main_loop.rs b/crates/service/job/inference_job/src/job/job_loop/main_loop.rs index 42317ed865..884b3306c3 100644 --- a/crates/service/job/inference_job/src/job/job_loop/main_loop.rs +++ b/crates/service/job/inference_job/src/job/job_loop/main_loop.rs @@ -35,6 +35,8 @@ pub async fn main_loop(job_dependencies: JobDependencies) { let mut sort_by_priority_count = 0; while !job_dependencies.job.system.application_shutdown.get() { + info!("Job loop iteration starting..."); + if let Some(pause_file) = job_dependencies.fs.maybe_pause_file.as_deref() { while file_exists(pause_file) { warn!("Pause file exists. Pausing until deleted: {:?}", pause_file); @@ -53,6 +55,8 @@ pub async fn main_loop(job_dependencies: JobDependencies) { let batch_query_start_time = Instant::now(); + info!("Querying jobs..."); + let maybe_available_jobs = list_available_generic_inference_jobs(ListAvailableGenericInferenceJobArgs { num_records: job_dependencies.job.system.job_batch_size, is_debug_worker: false, // TODO @@ -117,6 +121,8 @@ pub async fn main_loop(job_dependencies: JobDependencies) { error_timeout_millis = START_TIMEOUT_MILLIS; // reset + info!("Job loop batch processing complete. Sleeping {} ms", job_dependencies.job.system.job_batch_wait_millis); + std::thread::sleep(Duration::from_millis(job_dependencies.job.system.job_batch_wait_millis)); } @@ -192,6 +198,8 @@ async fn process_job_batch(job_dependencies: &JobDependencies, jobs: Vec