diff --git a/server/src/server.ts b/server/src/server.ts index 4d4550ca..ad2630c0 100644 --- a/server/src/server.ts +++ b/server/src/server.ts @@ -8,6 +8,7 @@ import { BrowserPool } from "./browser-management/classes/BrowserPool"; import logger from './logger' import { SERVER_PORT } from "./constants/config"; import {Server} from "socket.io"; +import { worker } from './workflow-management/scheduler'; const app = express(); app.use(cors()); @@ -34,4 +35,9 @@ app.get('/', function (req, res) { return res.send('Maxun server started 🚀'); }); +/** + * Starts the worker for the workflow queue. + */ +worker.run(); + server.listen(SERVER_PORT, () => logger.log('info',`Server listening on port ${SERVER_PORT}`));