Basic test for adding and removing nodes in cluster.
()
| 18 | |
| 19 | |
| 20 | def test_cluster(): |
| 21 | """Basic test for adding and removing nodes in cluster.""" |
| 22 | g = Cluster(initialize_head=False) |
| 23 | node = g.add_node() |
| 24 | node2 = g.add_node() |
| 25 | assert node.remaining_processes_alive() |
| 26 | assert node2.remaining_processes_alive() |
| 27 | g.remove_node(node2) |
| 28 | g.remove_node(node) |
| 29 | assert not any(n.any_processes_alive() for n in [node, node2]) |
| 30 | g.shutdown() |
| 31 | |
| 32 | |
| 33 | def test_shutdown(): |
nothing calls this directly
no test coverage detected
searching dependent graphs…