()
| 13 | |
| 14 | |
| 15 | def tutorial_cluster(): |
| 16 | b1, b2, b3 = MyNode1("nodeB1"), MyNode1("nodeB2", 3), MyNode2("nodeB3") |
| 17 | b_cluster = GCluster([b1, b2, b3]) # input is list[], means insert group(this is cluster), not for depend |
| 18 | |
| 19 | pipeline = GPipeline() |
| 20 | a, c, d = MyNode1(), MyNode2(), MyNode1() |
| 21 | |
| 22 | pipeline.registerGElement(a, set(), "nodeA") |
| 23 | pipeline.registerGElement(b_cluster, {a}, "clusterB", 2) |
| 24 | pipeline.registerGElement(c, {a}, "nodeC") |
| 25 | pipeline.registerGElement(d, {b_cluster, c}, "nodeD", 2) |
| 26 | |
| 27 | pipeline.process() |
| 28 | |
| 29 | |
| 30 | if __name__ == '__main__': |
no test coverage detected