()
| 13 | |
| 14 | |
| 15 | def tutorial_complex(): |
| 16 | pipeline = GPipeline() |
| 17 | b1, b2, b3 = MyNode1('nodeB1'), MyNode1('nodeB2'), MyNode2('nodeB3') |
| 18 | b_cluster = GCluster([b1, b2, b3]) |
| 19 | |
| 20 | d1, d2, d3 = MyNode1('nodeD1'), MyNode1('nodeD2'), MyNode1('nodeD3') |
| 21 | d4 = MyNode2({d1}, 'nodeD4', 1) |
| 22 | d23_cluster = GCluster([d2, d3]) # 表示 d23_cluster 中包含 [d2,d3] 两个element |
| 23 | d23_cluster.addDependGElements({d1}) # 表示 d23_cluster 依赖 {d1} 一个element，注意 [] 和 {} 的不用用法 |
| 24 | d_region = GRegion([d1, d23_cluster, d4]) |
| 25 | |
| 26 | a, c, e = MyNode1(), MyNode1(), MyNode1() |
| 27 | pipeline.registerGElement(a, set(), 'nodeA') |
| 28 | pipeline.registerGElement(b_cluster, set(), 'clusterB') |
| 29 | pipeline.registerGElement(c, {a, b_cluster}, 'nodeC') |
| 30 | pipeline.registerGElement(d_region, {a, b_cluster}, 'regionD', 2) |
| 31 | pipeline.registerGElement(e, {c, d_region}, 'nodeE') |
| 32 | |
| 33 | pipeline.process() |
| 34 | |
| 35 | |
| 36 | if __name__ == '__main__': |
no test coverage detected