From 3e19b27d735b568d7598a5b49b9f831aa08ddd8a Mon Sep 17 00:00:00 2001 From: mytharcher Date: Thu, 1 Aug 2024 12:36:49 +0000 Subject: [PATCH] test(server): avoid multiple installation in cluster --- packages/core/test/src/server/mock-server.ts | 2 +- .../plugin-workflow/src/server/__tests__/cluster.test.ts | 9 +++------ 2 files changed, 4 insertions(+), 7 deletions(-) diff --git a/packages/core/test/src/server/mock-server.ts b/packages/core/test/src/server/mock-server.ts index 73db8bec6b..c99b89b85c 100644 --- a/packages/core/test/src/server/mock-server.ts +++ b/packages/core/test/src/server/mock-server.ts @@ -285,7 +285,7 @@ export async function createMockCluster({ ...options, skipSupervisor: true, name: clusterName + '_' + appName, - // skipInstall: Boolean(i), + skipInstall: Boolean(i), pubSubManager: { channelPrefix: clusterName, }, diff --git a/packages/plugins/@nocobase/plugin-workflow/src/server/__tests__/cluster.test.ts b/packages/plugins/@nocobase/plugin-workflow/src/server/__tests__/cluster.test.ts index 17f9c0b5bd..86adeee367 100644 --- a/packages/plugins/@nocobase/plugin-workflow/src/server/__tests__/cluster.test.ts +++ b/packages/plugins/@nocobase/plugin-workflow/src/server/__tests__/cluster.test.ts @@ -42,7 +42,7 @@ describe('workflow > cluster', () => { const pro1 = (await p1.trigger(w1, {})) as Processor; expect(pro1.execution.status).toBe(EXECUTION_STATUS.RESOLVED); - await sleep(500); + await sleep(550); const p2 = app2.pm.get(Plugin) as Plugin; const w2 = p2.enabledCache.get(w1.id); @@ -59,11 +59,8 @@ describe('workflow > cluster', () => { const executions = await w1.getExecutions(); expect(executions.length).toBe(3); - await WorkflowRepo.update({ - filterByTk: w1.id, - values: { - enabled: false, - }, + await w1.update({ + enabled: false, }); await sleep(550);