diff --git a/jobs/queue.js b/jobs/queue.js index 840928f..ecbf2af 100644 --- a/jobs/queue.js +++ b/jobs/queue.js @@ -84,6 +84,7 @@ export const queue = new PQueue({ }); queue.on('add', () => broadcastQueueStats()); +queue.on('active', () => broadcastQueueStats()); queue.on('next', () => broadcastQueueStats()); queue.on('idle', () => broadcastQueueStats()); @@ -111,35 +112,6 @@ async function runJob(jobId) { try { const { meta } = resolveModelMeta(job.model); - // Robotics-ER models are available via the Gemini API but may not be - // exposed through all provider wrappers. Route them through @google/genai. - if (String(meta.id).startsWith('gemini-robotics-er-')) { - const inline = dataUrlToInlineData(job.imageDataUrl); - const contents = [ - { - role: 'user', - parts: [ - ...(inline ? [{ inlineData: inline }] : []), - { text: job.prompt ?? '' }, - ], - }, - ]; - - const res = await geminiApi.models.generateContent({ - model: meta.id, - contents, - }); - - const text = res?.text ?? ''; - - await setStatus(job, 'done', { - result: text, - inputTokens: null, - outputTokens: null, - }); - return; - } - const { text, usage } = await generateText({ model: resolveModel(job.model), messages: [