From 5ac862d334628f5d91f1efe4ccd63dfe53d11bd5 Mon Sep 17 00:00:00 2001 From: Nico Arqueros Date: Fri, 14 Feb 2025 23:04:05 -0300 Subject: [PATCH] fix --- .../shinkai-node/src/llm_provider/job_manager.rs | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/shinkai-bin/shinkai-node/src/llm_provider/job_manager.rs b/shinkai-bin/shinkai-node/src/llm_provider/job_manager.rs index 41041cce7..f996e16b8 100644 --- a/shinkai-bin/shinkai-node/src/llm_provider/job_manager.rs +++ b/shinkai-bin/shinkai-node/src/llm_provider/job_manager.rs @@ -287,9 +287,7 @@ impl JobManager { ) .await; - if result.is_ok() { - let _ = queue_immediate.lock().await.dequeue(&job_id).await; - } + let _ = queue_immediate.lock().await.dequeue(&job_id).await; let mut inprog = in_progress.lock().await; inprog.remove(&job_id); drop(permit); @@ -390,9 +388,7 @@ impl JobManager { ) .await; - if result.is_ok() { - let _ = queue_normal.lock().await.dequeue(&job_id).await; - } + let _ = queue_normal.lock().await.dequeue(&job_id).await; let mut inprog = in_progress.lock().await; inprog.remove(&job_id); drop(permit); @@ -446,9 +442,7 @@ impl JobManager { ) .await; - if result.is_ok() { - let _ = queue_immediate.lock().await.dequeue(&imm_id).await; - } + let _ = queue_immediate.lock().await.dequeue(&imm_id).await; let mut inprog = in_progress.lock().await; inprog.remove(&imm_id); drop(permit);