From 524b9770cd33e6be6a44b4fa18f3e7086e5b4ef1 Mon Sep 17 00:00:00 2001
From: Nicolas <nicolascamara29@gmail.com>
Date: Tue, 15 Apr 2025 17:52:20 -0700
Subject: [PATCH] Update queue-worker.ts

---
 apps/api/src/services/queue-worker.ts | 38 +++++++++++++--------------
 1 file changed, 19 insertions(+), 19 deletions(-)

diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts
index 3f096448..1118a0f9 100644
--- a/apps/api/src/services/queue-worker.ts
+++ b/apps/api/src/services/queue-worker.ts
@@ -433,25 +433,25 @@ const processExtractJobInternal = async (
   try {
     let result: ExtractResult | null = null;
 
-    // const model = job.data.request.agent?.model
-    // if (job.data.request.agent && model && model.toLowerCase().includes("fire-1")) {
-    //   result = await performExtraction(job.data.extractId, {
-    //     request: job.data.request,
-    //     teamId: job.data.teamId,
-    //     subId: job.data.subId,
-    //   });
-    // } else {
-    //   result = await performExtraction_F0(job.data.extractId, {
-    //     request: job.data.request,
-    //     teamId: job.data.teamId,
-    //     subId: job.data.subId,
-    //   });
-    // }
-    result = await performExtraction_F0(job.data.extractId, {
-      request: job.data.request,
-      teamId: job.data.teamId,
-      subId: job.data.subId,
-    });
+    const model = job.data.request.agent?.model
+    if (job.data.request.agent && model && model.toLowerCase().includes("fire-1")) {
+      result = await performExtraction(job.data.extractId, {
+        request: job.data.request,
+        teamId: job.data.teamId,
+        subId: job.data.subId,
+      });
+    } else {
+      result = await performExtraction_F0(job.data.extractId, {
+        request: job.data.request,
+        teamId: job.data.teamId,
+        subId: job.data.subId,
+      });
+    }
+    // result = await performExtraction_F0(job.data.extractId, {
+    //   request: job.data.request,
+    //   teamId: job.data.teamId,
+    //   subId: job.data.subId,
+    // });
 
     if (result && result.success) {
       // Move job to completed state in Redis