(model, distributed, local_rank)
| 22 | |
| 23 | |
| 24 | def parallelize(model, distributed, local_rank): |
| 25 | if distributed: |
| 26 | return nn.parallel.DistributedDataParallel( |
| 27 | model, |
| 28 | device_ids=[local_rank], |
| 29 | output_device=[local_rank], |
| 30 | find_unused_parameters=True) |
| 31 | else: |
| 32 | return nn.DataParallel(model) |
| 33 | |
| 34 | class SegDetectorModel(nn.Module): |
| 35 | def __init__(self, args, device, distributed: bool = False, local_rank: int = 0): |
no outgoing calls
no test coverage detected
searching dependent graphs…