Fix for queued jobs list
This commit is contained in:
@@ -84,6 +84,7 @@ export const queue = new PQueue({
|
|||||||
});
|
});
|
||||||
|
|
||||||
queue.on('add', () => broadcastQueueStats());
|
queue.on('add', () => broadcastQueueStats());
|
||||||
|
queue.on('active', () => broadcastQueueStats());
|
||||||
queue.on('next', () => broadcastQueueStats());
|
queue.on('next', () => broadcastQueueStats());
|
||||||
queue.on('idle', () => broadcastQueueStats());
|
queue.on('idle', () => broadcastQueueStats());
|
||||||
|
|
||||||
@@ -111,35 +112,6 @@ async function runJob(jobId) {
|
|||||||
try {
|
try {
|
||||||
const { meta } = resolveModelMeta(job.model);
|
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({
|
const { text, usage } = await generateText({
|
||||||
model: resolveModel(job.model),
|
model: resolveModel(job.model),
|
||||||
messages: [
|
messages: [
|
||||||
|
|||||||
Reference in New Issue
Block a user