vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: start worker in server

Browse Source
This commit is contained in:
Rohit Rajan
2025-09-10 00:20:18 +05:30
parent d92b62be00
commit b948ac9d9e
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/pgboss-worker.ts
View File

@@ -808,9 +808,6 @@ async function startWorkers() {
} }
} }
// Start all workers
startWorkers();
pgBoss.on('error', (error) => { pgBoss.on('error', (error) => {
logger.log('error', `PgBoss error: ${error.message}`); logger.log('error', `PgBoss error: ${error.message}`);
}); });
@@ -829,4 +826,4 @@ process.on('SIGINT', async () => {
}); });
// For use in other files // For use in other files
export { pgBoss }; export { pgBoss, startWorkers };

6
server/src/server.ts
View File

@@ -20,7 +20,8 @@ import connectPgSimple from 'connect-pg-simple';
import pg from 'pg'; import pg from 'pg';
import session from 'express-session'; import session from 'express-session';
import Run from './models/Run'; import Run from './models/Run';
import { processQueuedRuns } from './routes/storage'; import { processQueuedRuns, recoverOrphanedRuns } from './routes/storage';
import { startWorkers } from './pgboss-worker';
const app = express(); const app = express();
app.use(cors({ app.use(cors({
@@ -143,6 +144,9 @@ if (require.main === module) {
await connectDB(); await connectDB();
await syncDB(); await syncDB();
await recoverOrphanedRuns();
await startWorkers();
io = new Server(server); io = new Server(server);
io.of('/queued-run').on('connection', (socket) => { io.of('/queued-run').on('connection', (socket) => {