From 8c7c9ebd9c2f1a28beeab50fc798e86ad05b73a0 Mon Sep 17 00:00:00 2001 From: Pedro Novais <1478752+jpnovais@users.noreply.github.com> Date: Wed, 29 Jan 2025 16:32:30 +0000 Subject: [PATCH] coordinator: fix BlockCreationMonitorTest flacky test (#624) * coordinator: fix BlockCreationMonitorTest flacky test * coordinator: fix BlockCreationMonitorTest flacky test --- .../coordinator/blockcreation/BlockCreationMonitorTest.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/coordinator/app/src/test/kotlin/net/consensys/zkevm/coordinator/blockcreation/BlockCreationMonitorTest.kt b/coordinator/app/src/test/kotlin/net/consensys/zkevm/coordinator/blockcreation/BlockCreationMonitorTest.kt index d1ff7551..bed693e9 100644 --- a/coordinator/app/src/test/kotlin/net/consensys/zkevm/coordinator/blockcreation/BlockCreationMonitorTest.kt +++ b/coordinator/app/src/test/kotlin/net/consensys/zkevm/coordinator/blockcreation/BlockCreationMonitorTest.kt @@ -253,12 +253,12 @@ class BlockCreationMonitorTest { assertThat(blockCreationListener.blocksReceived).isNotEmpty assertThat(blockCreationListener.blocksReceived.last().number).isGreaterThanOrEqualTo(103u) } - fakeL2RpcNode.stopHttpServer() + fakeL2RpcNode.stopHttpServer().get() val lastBlockReceived = blockCreationListener.blocksReceived.last().number // Wait for a while to make sure no more blocks are fetched await().atLeast(config.pollingInterval.times(2).toJavaDuration()) - fakeL2RpcNode.resumeHttpServer() + fakeL2RpcNode.resumeHttpServer().get() await() .atMost(40.seconds.toJavaDuration()) .untilAsserted {