(nodes)
| 209 | return {"o3": F.max(nodes.mailbox["m1"], 1)} |
| 210 | |
| 211 | def _afunc(nodes): |
| 212 | ret = {} |
| 213 | for k, v in nodes.data.items(): |
| 214 | if k.startswith("o"): |
| 215 | ret[k] = 2 * v |
| 216 | return ret |
| 217 | |
| 218 | # compute ground truth |
| 219 | g.update_all(_mfunc_hxw1, _rfunc_m1, _afunc) |