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

fix(core): Ensure worker stops picking up new jobs while shutting down (#13714)

Browse Source
This commit is contained in:
Iván Ovejero
2025-03-10 17:39:41 +01:00
committed by GitHub
parent cbf2476819
commit 4fe249580a
2 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -202,7 +202,7 @@ describe('ScalingService', () => {
});
describe('if worker', () => {
it('should wait for running jobs to finish', async () => {
it('should pause queue and wait for running jobs to finish', async () => {
// @ts-expect-error readonly property
instanceSettings.instanceType = 'worker';
await scalingService.setupQueue();
@@ -211,7 +211,7 @@ describe('ScalingService', () => {
await scalingService.stop();
expect(getRunningJobsCountSpy).toHaveBeenCalled();
expect(queue.pause).not.toHaveBeenCalled();
expect(queue.pause).toHaveBeenCalled();
expect(stopQueueRecoverySpy).not.toHaveBeenCalled();
});
});