From 3946e5c2442c6394ddada69fadfb19789bd264ff Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Iv=C3=A1n=20Ovejero?= <ivov.src@gmail.com>
Date: Wed, 11 Jun 2025 13:37:22 +0200
Subject: [PATCH] test(core): Unskip and fix workflow runner test (#16227)

---
 packages/cli/src/__tests__/workflow-runner.test.ts | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git a/packages/cli/src/__tests__/workflow-runner.test.ts b/packages/cli/src/__tests__/workflow-runner.test.ts
index b375c4b883..3d237e9f49 100644
--- a/packages/cli/src/__tests__/workflow-runner.test.ts
+++ b/packages/cli/src/__tests__/workflow-runner.test.ts
@@ -259,15 +259,15 @@ describe('run', () => {
 	});
 });
 
-// eslint-disable-next-line n8n-local-rules/no-skipped-tests
-describe.skip('enqueueExecution', () => {
+describe('enqueueExecution', () => {
 	const setupQueue = jest.fn();
+	const addJob = jest.fn();
 
 	@Service()
 	class MockScalingService {
 		setupQueue = setupQueue;
 
-		addJob = jest.fn();
+		addJob = addJob;
 	}
 
 	beforeAll(() => {
@@ -288,9 +288,14 @@ describe.skip('enqueueExecution', () => {
 			workflowData: { nodes: [] },
 			executionData: undefined,
 		});
+		const error = new Error('stop for test purposes');
+
+		// mock a rejection to stop execution flow before we create the PCancelable promise,
+		// so that Jest does not move on to tear down the suite until the PCancelable settles
+		addJob.mockRejectedValueOnce(error);
 
 		// @ts-expect-error Private method
-		await runner.enqueueExecution('1', data);
+		await expect(runner.enqueueExecution('1', data)).rejects.toThrowError(error);
 
 		expect(setupQueue).toHaveBeenCalledTimes(1);
 	});