diff --git a/apps/api/src/services/indexing/index-worker.ts b/apps/api/src/services/indexing/index-worker.ts index 0b38b90a..30285978 100644 --- a/apps/api/src/services/indexing/index-worker.ts +++ b/apps/api/src/services/indexing/index-worker.ts @@ -156,7 +156,8 @@ const workerFun = async (queue: Queue, jobProcessor: (token: string, job: Job) = const canAcceptConnection = await monitor.acceptConnection(); if (!canAcceptConnection) { - logger.info("Cant accept connection"); + console.log("Can't accept connection due to RAM/CPU load"); + logger.info("Can't accept connection due to RAM/CPU load"); cantAcceptConnectionCount++; if (cantAcceptConnectionCount >= 25) { diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts index 5493da73..96de8d72 100644 --- a/apps/api/src/services/queue-worker.ts +++ b/apps/api/src/services/queue-worker.ts @@ -567,7 +567,8 @@ const workerFun = async ( const token = uuidv4(); const canAcceptConnection = await monitor.acceptConnection(); if (!canAcceptConnection) { - console.log("Cant accept connection"); + console.log("Can't accept connection due to RAM/CPU load"); + logger.info("Can't accept connection due to RAM/CPU load"); cantAcceptConnectionCount++; if (cantAcceptConnectionCount >= 25) {