test: Solving an intermittent test failure under high parallel test load

algorandfoundation · Mar 25, 2024 · c373221 · c373221
1 parent 608482f
commit c373221
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tests/scenarios/subscriber.spec.ts b/tests/scenarios/subscriber.spec.ts
@@ -154,9 +154,9 @@ describe('AlgorandSubscriber', () => {
     expect(subscribedTxns[2].id).toBe(txIds1[1])
     expect(subscribedTxns[3].id).toBe(txIds2[0])
     expect(subscribedTxns[4].id).toBe(txIds2[1])
-    expect(getWatermark()).toBe(lastTxnRound)
     expect(result.currentRound).toBeGreaterThanOrEqual(lastTxnRound)
     expect(result.newWatermark).toBe(result.currentRound)
+    expect(getWatermark()).toBeGreaterThanOrEqual(result.currentRound)
     expect(result.syncedRoundRange).toEqual([firstTxnRound, result.currentRound])
     expect(result.subscribedTransactions.length).toBe(5)
     expect(result.subscribedTransactions.map((t) => t.id)).toEqual(txIds.concat(txIds1, txIds2))
@@ -188,9 +188,9 @@ describe('AlgorandSubscriber', () => {
     expect(subscribedTxns3[2].id).toBe(txIds13[1])
     expect(subscribedTxns3[3].id).toBe(txIds23[0])
     expect(subscribedTxns3[4].id).toBe(txIds23[1])
-    expect(getWatermark()).toBeGreaterThanOrEqual(lastSubscribedRound3)
     expect(result3.currentRound).toBeGreaterThanOrEqual(lastSubscribedRound3)
     expect(result3.newWatermark).toBe(result3.currentRound)
+    expect(getWatermark()).toBeGreaterThanOrEqual(result3.currentRound)
     expect(result3.syncedRoundRange).toEqual([result2.newWatermark + 1, result3.currentRound])
     expect(result3.subscribedTransactions.length).toBe(5)
     expect(result3.subscribedTransactions.map((t) => t.id)).toEqual(txIds3.concat(txIds13, txIds23))