feat(local-server-stress-tests): increase ops before attach to 100

- Increase creationPhaseOps from 7 to 20
- Increase numOpsBeforeAttach from 20 to 100
- Increase total ops per test from 100 to 200
- Disable createDataStore/createChannel during DDS ops phase
- Clear pendingLocalStateStore in test cleanup

Co-Authored-By: anthony-murphy <[email protected]>
Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: 3 people

packages/test/local-server-stress-tests/src/baseModel.ts

@@ -79,9 +79,9 @@ export const reducer = combineReducersAsync<StressOperations, LocalServerStressS
 
 /**
  * Number of operations in the "creation phase" before attach.
- * During this phase, we prioritize creating datastores and channels.
+ * During this phase, only createDataStore and createChannel operations are generated.
  */
-const creationPhaseOps = 7;
+const creationPhaseOps = 20;
 
 export function makeGenerator<T extends BaseOperation>(
 	additional: DynamicAsyncWeights<T, LocalServerStressState> = [],
@@ -116,8 +116,8 @@ export function makeGenerator<T extends BaseOperation>(
 				asChild: state.random.bool(),
 				tag: state.tag("datastore"),
 			}),
-			// High weight during creation phase, low weight otherwise
-			(state) => (isCreationPhase(state) ? 20 : 1),
+			// Only during creation phase (detached), normal weight when attached
+			(state) => (isDdsOpsPhase(state) ? 0 : isCreationPhase(state) ? 20 : 1),
 		],
 		[
 			async (state) => ({
@@ -134,8 +134,8 @@ export function makeGenerator<T extends BaseOperation>(
 				channelType: state.random.pick([...ddsModelMap.keys()]),
 				tag: state.tag("channel"),
 			}),
-			// High weight during creation phase, low weight otherwise
-			(state) => (isCreationPhase(state) ? 20 : 5),
+			// Only during creation phase (detached), normal weight when attached
+			(state) => (isDdsOpsPhase(state) ? 0 : isCreationPhase(state) ? 20 : 5),
 		],
 		[
 			async () => ({
@@ -158,10 +158,10 @@ export function makeGenerator<T extends BaseOperation>(
 		],
 		[
 			DDSModelOpGenerator,
-			// Low weight during creation phase, high weight during DDS ops phase
+			// No DDS ops during creation phase, high weight during DDS ops phase
 			(state) => {
 				if (isCreationPhase(state)) {
-					return 10;
+					return 0;
 				}
 				if (isDdsOpsPhase(state)) {
 					return 150;

packages/test/local-server-stress-tests/src/localServerStressHarness.ts

@@ -77,7 +77,7 @@ import { validateConsistencyOfAllDDS } from "./ddsOperations.js";
 import {
 	createRuntimeFactory,
 	StressDataObject,
-	type DefaultStressDataObject,
+	DefaultStressDataObject,
 } from "./stressDataObject.js";
 import { makeUnreachableCodePathProxy } from "./utils.js";
 
@@ -379,7 +379,7 @@ export interface LocalServerStressOptions {
 const defaultLocalServerStressSuiteOptions: LocalServerStressOptions = {
 	defaultTestCount: 100,
 	detachedStartOptions: {
-		numOpsBeforeAttach: 20,
+		numOpsBeforeAttach: 100,
 	},
 	numberOfClients: 3,
 	clientJoinOptions: {
@@ -1109,6 +1109,7 @@ async function runTestForSeed<TOperation extends BaseOperation>(
 
 			finalState.validationClient.container.dispose();
 			await finalState.localDeltaConnectionServer.close();
+			finalState.pendingLocalStateStore.clear();
 		}
 	}
 

packages/test/local-server-stress-tests/src/test/localServerStress.spec.ts

@@ -22,7 +22,7 @@ import {
 describe("Local Server Stress", () => {
 	const model: LocalServerStressModel<StressOperations> = {
 		workloadName: "default",
-		generatorFactory: () => takeAsync(100, makeGenerator()),
+		generatorFactory: () => takeAsync(200, makeGenerator()),
 		reducer,
 		validateConsistency: async (...clients) => {
 			await validateAllDataStoresSaved(...clients);