logos-blockchain/logos-blockchain-e2e-tests
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-e2e-tests.git synced 2026-01-04 06:03:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: ensure ready after all nodes have started

Browse Source
This commit is contained in:
Roman 2025-01-13 16:07:13 +08:00
parent c7a956acbb
commit 7ff4f4a19d
No known key found for this signature in database
GPG Key ID: B8FE070B54E11B75
2 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/node/nomos_node.py
View File

@ -81,12 +81,6 @@ class NomosNode:
logger.debug(f"Container returned {self._container}") logger.debug(f"Container returned {self._container}")
logger.debug(f"Started container from image {self._image_name}. " f"REST: {getattr(self, '_tcp_port', 'N/A')}") logger.debug(f"Started container from image {self._image_name}. " f"REST: {getattr(self, '_tcp_port', 'N/A')}")
# try:
# self.ensure_ready(timeout_duration=wait_for_node_sec)
# except Exception as ex:
# logger.error(f"REST service did not become ready in time: {ex}")
# raise
def ensure_ready(self, timeout_duration=10): def ensure_ready(self, timeout_duration=10):
@retry(stop=stop_after_delay(timeout_duration), wait=wait_fixed(0.1), reraise=True) @retry(stop=stop_after_delay(timeout_duration), wait=wait_fixed(0.1), reraise=True)
def check_ready(node=self): def check_ready(node=self):

11
tests/e2e/test_2node_alive.py
View File

@ -1,7 +1,10 @@
from src.env_vars import CFGSYNC, NOMOS, NOMOS_EXECUTOR from src.env_vars import CFGSYNC, NOMOS, NOMOS_EXECUTOR
from src.libs.custom_logger import get_custom_logger
from src.node.nomos_node import NomosNode from src.node.nomos_node import NomosNode
from src.libs.common import delay from src.libs.common import delay
logger = get_custom_logger(__name__)
class Test2NodeClAlive: class Test2NodeClAlive:
def test_cluster_start(self): def test_cluster_start(self):
@ -14,4 +17,12 @@ class Test2NodeClAlive:
self.node2.start() self.node2.start()
self.node3.start() self.node3.start()
self.node1.ensure_ready()
try:
self.node2.ensure_ready()
self.node3.ensure_ready()
except Exception as ex:
logger.error(f"REST service did not become ready in time: {ex}")
raise
delay(60) delay(60)