Vladsz83 commented on a change in pull request #8124:
URL: https://github.com/apache/ignite/pull/8124#discussion_r466362458
##########
File path: modules/ducktests/tests/ignitetest/tests/discovery_test.py
##########
@@ -139,24 +179,33 @@ def __basic_test__(self, version, with_zk=False):
data["node_disco_info"] = disco_infos
- self.servers.stop_node(fail_node, clean_shutdown=False)
-
start = self.monotonic()
- self.servers.await_event_on_node("Node FAILED",
random.choice(survived_node), 60, True)
+
+ ids_to_wait = [node.discovery_info().node_id for node in failed_nodes]
+
+ self.servers.stop_nodes_async(failed_nodes, clean_shutdown=False,
delay_ms=delay_ms)
+
+ for failed_id in ids_to_wait:
+ self.stage("Waiting for stopping " + failed_id)
+
+ self.servers.await_event_on_node("Node FAILED: TcpDiscoveryNode
\\[id=" + failed_id, survived_node, 30,
+ from_the_beginning=True)
data['Failure of node detected in time (s)'] = self.monotonic() - start
Review comment:
Fixed
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
