CERBERUS/LibreChat
1
0
Fork 0
mirror of https://github.com/danny-avila/LibreChat.git synced 2026-05-13 16:07:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

fix: assign retention sweep worker deterministically

Browse source
This commit is contained in:
Danny Avila 2026-05-10 20:44:16 -04:00
parent 599e46d004
commit 3529a02c15
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
api/server/experimental.js
View file

@ -140,6 +140,7 @@ if (cluster.isMaster) {
logger.info(`Spawning ${workers} workers to simulate multi-pod environment`);
let activeWorkers = 0;
const listeningWorkers = new Set();
let retentionSweepWorkerId = null;
const startTime = Date.now();
@ -188,14 +189,16 @@ if (cluster.isMaster) {
}
});
cluster.on('listening', () => {
if (activeWorkers === workers) {
cluster.on('listening', (worker) => {
listeningWorkers.add(worker.id);
if (listeningWorkers.size === workers) {
assignRetentionSweepWorker();
}
});
cluster.on('exit', (worker, code, signal) => {
activeWorkers--;
listeningWorkers.delete(worker.id);
if (worker.id === retentionSweepWorkerId) {
retentionSweepWorkerId = null;
}