Merge pull request #873 from dcSpark/nico/fix_endless_msg_error

fix endless msg error
dcSpark · Feb 16, 2025 · 56b2313 · 56b2313
2 parents 8361ff2 + 5ac862d
commit 56b2313
Showing 1 changed file with 3 additions and 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
@@ -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);