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);