()
| 126 | dist.distributed_c10d._world = dist.distributed_c10d._World() |
| 127 | |
| 128 | def _save_world(): |
| 129 | save_dict = {} |
| 130 | for key in [ |
| 131 | "_pg_map", "_pg_names", "_pg_group_ranks", "_pg_backend_config", "_pg_to_tag", "_tags_to_pg" |
| 132 | ]: |
| 133 | if hasattr(dist.distributed_c10d, key): |
| 134 | save_dict[key] = getattr(dist.distributed_c10d, key) |
| 135 | save_world = dist.distributed_c10d._world |
| 136 | return save_dict, save_world |
| 137 | |
| 138 | def _load_world(load_dict, load_world): |
| 139 | for key, val in load_dict.items(): |
no outgoing calls
no test coverage detected