Revert reentry stress tests next - again (microsoft#13710)

_The fix in next was overwritten by an integration from main_ Original PR: microsoft#13620 OP Reentry in the stress tests is still causing test incidents in next due to the lifecycle of the container. This requires more refactoring of the stress tests. Until then, these configs should be decoupled and the reentry feature disabled in the stress tests in order to continue having test coverage for compression.
aeyalcinoglu · Jan 20, 2023 · 8b763d8 · 8b763d8
1 parent 067332d
commit 8b763d8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 15 deletions.
diff --git a/packages/test/test-service-load/src/loadTestDataStore.ts b/packages/test/test-service-load/src/loadTestDataStore.ts
@@ -225,14 +225,8 @@ export class LoadTestDataStoreModel {
         this.partnerId = (this.config.runId + halfClients) % this.config.testConfig.numClients;
         const changed = (taskId) => {
             if (taskId === this.taskId && this.taskStartTime !== 0) {
-                Promise.resolve().then(() => {
-                    this.dir.set(taskTimeKey, this.totalTaskTime);
-                    this.taskStartTime = 0;
-                }).catch((error) => {
-                    this.logger.sendErrorEvent({
-                        eventName: "TaskManager_OnValueChanged",
-                    }, error);
-                });
+                this.dir.set(taskTimeKey, this.totalTaskTime);
+                this.taskStartTime = 0;
             }
         };
         this.taskManager.on("lost", changed);
@@ -262,12 +256,7 @@ export class LoadTestDataStoreModel {
                     : Math.trunc(value * blobsPerOp - this.blobCount);
 
                 if (newBlobs > 0) {
-                    Promise.resolve().then(() => {
-                        this.blobUploads.push(...[...Array(newBlobs)].map(async () => this.writeBlob(this.blobCount++)));
-                    }).catch((error) => this.logger.sendErrorEvent({
-                        eventName: "WriteBlobFailed_OnCounterValueChanged",
-                        count: this.blobCount,
-                    }, error));
+                    this.blobUploads.push(...[...Array(newBlobs)].map(async () => this.writeBlob(this.blobCount++)));
                 }
             });
         }

diff --git a/packages/test/test-service-load/src/optionsMatrix.ts b/packages/test/test-service-load/src/optionsMatrix.ts
@@ -78,7 +78,7 @@ export function generateRuntimeOptions(
         flushMode: [undefined],
         compressionOptions: [{ minimumBatchSizeInBytes: 500, compressionAlgorithm: CompressionAlgorithms.lz4 }],
         maxBatchSizeInBytes: [undefined],
-        enableOpReentryCheck: [true],
+        enableOpReentryCheck: [undefined],
         chunkSizeInBytes: [undefined],
     };