From b948ac9d9e9b2a822d97b55112f51a7afc49d074 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Wed, 10 Sep 2025 00:20:18 +0530
Subject: [PATCH] feat: start worker in server

---
 server/src/pgboss-worker.ts | 5 +----
 server/src/server.ts        | 6 +++++-
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/server/src/pgboss-worker.ts b/server/src/pgboss-worker.ts
index fe30dbd8..ce46e830 100644
--- a/server/src/pgboss-worker.ts
+++ b/server/src/pgboss-worker.ts
@@ -808,9 +808,6 @@ async function startWorkers() {
   }
 }
 
-// Start all workers
-startWorkers();
-
 pgBoss.on('error', (error) => {
   logger.log('error', `PgBoss error: ${error.message}`);
 });
@@ -829,4 +826,4 @@ process.on('SIGINT', async () => {
 });
 
 // For use in other files
-export { pgBoss };
+export { pgBoss, startWorkers };
diff --git a/server/src/server.ts b/server/src/server.ts
index 5b729b72..35ce7705 100644
--- a/server/src/server.ts
+++ b/server/src/server.ts
@@ -20,7 +20,8 @@ import connectPgSimple from 'connect-pg-simple';
 import pg from 'pg';
 import session from 'express-session';
 import Run from './models/Run';
-import { processQueuedRuns } from './routes/storage';
+import { processQueuedRuns, recoverOrphanedRuns } from './routes/storage';
+import { startWorkers } from './pgboss-worker';
 
 const app = express();
 app.use(cors({
@@ -143,6 +144,9 @@ if (require.main === module) {
       await connectDB();
       await syncDB();
       
+      await recoverOrphanedRuns();
+      await startWorkers();
+      
       io = new Server(server);
       
       io.of('/queued-run').on('connection', (socket) => {