admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-16 17:46:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(core): Make first queue reconciliation immediate on startup (#18490)

Browse Source
This commit is contained in:
Iván Ovejero
2025-08-19 10:55:52 +02:00
committed by GitHub
parent 06b586af44
commit 961fc538d7
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/cli/src/scaling/__tests__/scaling.service.test.ts
View File

@@ -118,7 +118,7 @@ describe('ScalingService', () => {
expect(Bull).toHaveBeenCalledWith(...bullConstructorArgs);
expect(registerMainOrWebhookListenersSpy).toHaveBeenCalled();
expect(registerWorkerListenersSpy).not.toHaveBeenCalled();
expect(scheduleQueueRecoverySpy).toHaveBeenCalled();
expect(scheduleQueueRecoverySpy).toHaveBeenCalledWith(0);
});
});

4
packages/cli/src/scaling/scaling.service.ts
View File

@@ -73,7 +73,7 @@ export class ScalingService {
this.registerListeners();
if (this.instanceSettings.isLeader) this.scheduleQueueRecovery();
if (this.instanceSettings.isLeader) this.scheduleQueueRecovery(0);
this.scheduleQueueMetrics();
@@ -460,6 +460,8 @@ export class ScalingService {
}
}, waitMs);
if (waitMs === 0) return;
const wait = [this.queueRecoveryContext.waitMs / Time.minutes.toMilliseconds, 'min'].join(' ');
this.logger.debug(`Scheduled queue recovery check for next ${wait}`);