towsty/aigen
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Kick the studio dispatcher when the UI polls a stalled waiting queue.

Browse Source 
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
Towsty
2026-09-04 14:14:26 -05:00
co-authored by Cursor
parent 91855a0103
commit 41ba5e3aab
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/api/studio-queue.get.ts
+7 -2
View File
@@ -1,5 +1,5 @@
import { listShotQueues, summarizeQueue } from '~/server/utils/shotQueue' import { listShotQueues, summarizeQueue } from '~/server/utils/shotQueue'
import { listStudioJobs, summarizeStudioJob } from '~/server/utils/studioQueue' import { kickStudioQueue, listStudioJobs, summarizeStudioJob } from '~/server/utils/studioQueue'
export default defineEventHandler((event) => { export default defineEventHandler((event) => {
const { owner } = assertLibraryOwner(event) const { owner } = assertLibraryOwner(event)
@@ -54,10 +54,15 @@ export default defineEventHandler((event) => {
.filter(queue => !claimed.has(queue.id) && queue.status !== 'complete') .filter(queue => !claimed.has(queue.id) && queue.status !== 'complete')
.map(summarizeQueue) .map(summarizeQueue)
: [] : []
const waitingCount = jobs.filter(job => job.status === 'waiting').length
// Nudge the dispatcher whenever the UI polls a stalled waiting queue.
if (waitingCount > 0 && !jobs.some(job => job.status === 'running')) {
void kickStudioQueue()
}
return { return {
jobs, jobs,
orphans, orphans,
waitingCount: jobs.filter(job => job.status === 'waiting').length, waitingCount,
paused: jobs.some(job => job.pausedByUser === true) paused: jobs.some(job => job.pausedByUser === true)
|| orphans.some(queue => queue.stopAfterCurrent === true && queue.status !== 'running'), || orphans.some(queue => queue.stopAfterCurrent === true && queue.status !== 'running'),
willPause: jobs.some(job => ( willPause: jobs.some(job => (