Update queue-worker.ts

This commit is contained in:
Nicolas 2025-04-15 17:52:20 -07:00
parent c8a8e96acc
commit 524b9770cd

View File

@ -433,25 +433,25 @@ const processExtractJobInternal = async (
try { try {
let result: ExtractResult | null = null; let result: ExtractResult | null = null;
// const model = job.data.request.agent?.model const model = job.data.request.agent?.model
// if (job.data.request.agent && model && model.toLowerCase().includes("fire-1")) { if (job.data.request.agent && model && model.toLowerCase().includes("fire-1")) {
// result = await performExtraction(job.data.extractId, { result = await performExtraction(job.data.extractId, {
// request: job.data.request, request: job.data.request,
// teamId: job.data.teamId, teamId: job.data.teamId,
// subId: job.data.subId, subId: job.data.subId,
// }); });
// } else { } 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, { result = await performExtraction_F0(job.data.extractId, {
request: job.data.request, request: job.data.request,
teamId: job.data.teamId, teamId: job.data.teamId,
subId: job.data.subId, 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) { if (result && result.success) {
// Move job to completed state in Redis // Move job to completed state in Redis