From 1ab388ed033ab943b0e98811bac8b469feed8843 Mon Sep 17 00:00:00 2001
From: Sidney Anderson <sa@sidneyanderson>
Date: Tue, 26 May 2026 07:21:19 -0600
Subject: [PATCH 1/2] fix: restart queue when a job is queued
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

When the worker queue drains, it sets is_running=false on the Queue
record. If a new job is then queued, the worker's loop skips it
entirely because is_running=false — the job sits frozen until the
user manually starts the queue.

Fix: always set is_running=true on the queue when a job is queued,
mirroring what the /api/queue/[queueID]/start route already does.
Also fixes the create-path which was creating the queue with
is_running=false, meaning a brand-new queue would also never start.
---
 ui/src/app/api/jobs/[jobID]/start/route.ts | 59 ----------------------
 1 file changed, 59 deletions(-)

diff --git a/ui/src/app/api/jobs/[jobID]/start/route.ts b/ui/src/app/api/jobs/[jobID]/start/route.ts
index 0417dcff..e69de29b 100644
--- a/ui/src/app/api/jobs/[jobID]/start/route.ts
+++ b/ui/src/app/api/jobs/[jobID]/start/route.ts
@@ -1,59 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server';
-import { PrismaClient } from '@prisma/client';
-
-const prisma = new PrismaClient();
-
-export async function GET(request: NextRequest, { params }: { params: { jobID: string } }) {
-  const { jobID } = await params;
-
-  const job = await prisma.job.findUnique({
-    where: { id: jobID },
-  });
-
-  if (!job) {
-    return NextResponse.json({ error: 'Job not found' }, { status: 404 });
-  }
-
-  // get highest queue position
-  const highestQueuePosition = await prisma.job.aggregate({
-    _max: {
-      queue_position: true,
-    },
-  });
-  const newQueuePosition = (highestQueuePosition._max.queue_position || 0) + 1000;
-
-  await prisma.job.update({
-    where: { id: jobID },
-    data: { queue_position: newQueuePosition },
-  });
-
-  // make sure the queue is running
-  const queue = await prisma.queue.findFirst({
-    where: {
-      gpu_ids: job.gpu_ids,
-    },
-  });
-
-  // if queue doesn't exist, create it
-  if (!queue) {
-    await prisma.queue.create({
-      data: {
-        gpu_ids: job.gpu_ids,
-        is_running: false,
-      },
-    });
-  }
-
-  await prisma.job.update({
-    where: { id: jobID },
-    data: {
-      status: 'queued',
-      stop: false,
-      return_to_queue: false,
-      info: 'Job queued',
-    },
-  });
-
-  // Return the response immediately
-  return NextResponse.json(job);
-}

From f4036a93ec48dd39a917ea6b7f20809fba33e1f1 Mon Sep 17 00:00:00 2001
From: Sidney Anderson <sa@sidneyanderson>
Date: Tue, 26 May 2026 07:22:30 -0600
Subject: [PATCH 2/2] fix: restart queue when a job is queued
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

When the worker queue drains, it sets is_running=false on the Queue
record. If a new job is then queued, the worker's loop skips it
entirely because is_running=false — the job sits frozen until the
user manually starts the queue.

Fix: always set is_running=true on the queue when a job is queued,
mirroring what the /api/queue/[queueID]/start route already does.
Also fixes the create-path which was creating the queue with
is_running=false, meaning a brand-new queue would also never start.
---
 ui/src/app/api/jobs/[jobID]/start/route.ts | 65 ++++++++++++++++++++++
 1 file changed, 65 insertions(+)

diff --git a/ui/src/app/api/jobs/[jobID]/start/route.ts b/ui/src/app/api/jobs/[jobID]/start/route.ts
index e69de29b..52704335 100644
--- a/ui/src/app/api/jobs/[jobID]/start/route.ts
+++ b/ui/src/app/api/jobs/[jobID]/start/route.ts
@@ -0,0 +1,65 @@
+import { NextRequest, NextResponse } from 'next/server';
+import { PrismaClient } from '@prisma/client';
+
+const prisma = new PrismaClient();
+
+export async function GET(request: NextRequest, { params }: { params: { jobID: string } }) {
+  const { jobID } = await params;
+
+  const job = await prisma.job.findUnique({
+    where: { id: jobID },
+  });
+
+  if (!job) {
+    return NextResponse.json({ error: 'Job not found' }, { status: 404 });
+  }
+
+  // get highest queue position
+  const highestQueuePosition = await prisma.job.aggregate({
+    _max: {
+      queue_position: true,
+    },
+  });
+  const newQueuePosition = (highestQueuePosition._max.queue_position || 0) + 1000;
+
+  await prisma.job.update({
+    where: { id: jobID },
+    data: { queue_position: newQueuePosition },
+  });
+
+  // make sure the queue exists and is running
+  const queue = await prisma.queue.findFirst({
+    where: {
+      gpu_ids: job.gpu_ids,
+    },
+  });
+
+  // if queue doesn't exist, create it and start it
+  if (!queue) {
+    await prisma.queue.create({
+      data: {
+        gpu_ids: job.gpu_ids,
+        is_running: true,
+      },
+    });
+  } else {
+    // ensure the queue is running so the worker picks up the new job
+    await prisma.queue.update({
+      where: { id: queue.id },
+      data: { is_running: true },
+    });
+  }
+
+  await prisma.job.update({
+    where: { id: jobID },
+    data: {
+      status: 'queued',
+      stop: false,
+      return_to_queue: false,
+      info: 'Job queued',
+    },
+  });
+
+  // Return the response immediately
+  return NextResponse.json(job);
+}