From 1fa960eb9e8de1941526cd07e6d7db99d135b237 Mon Sep 17 00:00:00 2001 From: Eric <5089238+emizzle@users.noreply.github.com> Date: Fri, 6 Jun 2025 18:33:19 +1000 Subject: [PATCH] fix(integration): add timeouts to waiting for started futures --- tests/integration/30_minutes/testmarketplace.nim | 2 +- tests/integration/30_minutes/testproofs.nim | 2 +- tests/integration/5_minutes/testsales.nim | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/integration/30_minutes/testmarketplace.nim b/tests/integration/30_minutes/testmarketplace.nim index b93b7697..ee8e84f6 100644 --- a/tests/integration/30_minutes/testmarketplace.nim +++ b/tests/integration/30_minutes/testmarketplace.nim @@ -290,7 +290,7 @@ marketplacesuite(name = "Marketplace payouts", stopOnRequestFail = true): # wait until sale is cancelled await ethProvider.advanceTime(expiry.u256) - await requestCancelledEvent.wait().wait(timeout = chronos.seconds(5)) + await requestCancelledEvent.wait().wait(timeout = chronos.seconds(expiry.int + 10)) await advanceToNextPeriod() diff --git a/tests/integration/30_minutes/testproofs.nim b/tests/integration/30_minutes/testproofs.nim index c0a3b102..f7a2cd10 100644 --- a/tests/integration/30_minutes/testproofs.nim +++ b/tests/integration/30_minutes/testproofs.nim @@ -64,7 +64,7 @@ marketplacesuite(name = "Hosts submit regular proofs", stopOnRequestFail = false let slotSize = slotSize(blocks, ecNodes, ecTolerance) - discard await waitForRequestToStart(expiry.int) + discard await waitForRequestToStart(expiry.int + 10) var proofWasSubmitted = false proc onProofSubmitted(event: ?!ProofSubmitted) = diff --git a/tests/integration/5_minutes/testsales.nim b/tests/integration/5_minutes/testsales.nim index 246d8fc7..a4cf06a7 100644 --- a/tests/integration/5_minutes/testsales.nim +++ b/tests/integration/5_minutes/testsales.nim @@ -140,7 +140,7 @@ marketplacesuite(name = "Sales", stopOnRequestFail = true): tolerance = 1, ) - discard await waitForRequestToStart() + discard await waitForRequestToStart((10 * 60) + 10) let updatedAvailability = ((await host.getAvailabilities()).get).findItem(availability).get @@ -215,7 +215,7 @@ marketplacesuite(name = "Sales", stopOnRequestFail = true): ) ).get - discard await waitForRequestToStart() + discard await waitForRequestToStart((10*60)+10) let purchase = (await client.getPurchase(id)).get check purchase.error == none string