(tensor, expected=None)
| 261 | |
| 262 | |
| 263 | def _check_device(tensor, expected=None): |
| 264 | if not device.canonical_name(tensor.device): |
| 265 | raise ValueError('Device assignment required for nccl collective ops') |
| 266 | if expected and expected != tensor.device: |
| 267 | raise ValueError('Expected device %s, got %s' % (expected, tensor.device)) |
no test coverage detected