feat: run worker
This commit is contained in:
@@ -8,6 +8,7 @@ import { BrowserPool } from "./browser-management/classes/BrowserPool";
|
|||||||
import logger from './logger'
|
import logger from './logger'
|
||||||
import { SERVER_PORT } from "./constants/config";
|
import { SERVER_PORT } from "./constants/config";
|
||||||
import {Server} from "socket.io";
|
import {Server} from "socket.io";
|
||||||
|
import { worker } from './workflow-management/scheduler';
|
||||||
|
|
||||||
const app = express();
|
const app = express();
|
||||||
app.use(cors());
|
app.use(cors());
|
||||||
@@ -34,4 +35,9 @@ app.get('/', function (req, res) {
|
|||||||
return res.send('Maxun server started 🚀');
|
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}`));
|
server.listen(SERVER_PORT, () => logger.log('info',`Server listening on port ${SERVER_PORT}`));
|
||||||
|
|||||||
Reference in New Issue
Block a user