memory optimization and queue fix

This commit is contained in:
Per Stark
2025-01-14 13:41:36 +01:00
parent 2d96f06478
commit 972919a515
5 changed files with 15 additions and 19 deletions

View File

@@ -48,9 +48,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
info!("Found {} unfinished jobs", unfinished_jobs.len());
for job in unfinished_jobs {
if let Err(e) = job_queue.process_job(job.clone(), &content_processor).await {
error!("Error processing job {}: {}", job.id, e);
}
job_queue.process_job(job, &content_processor).await?;
}
}