fix distributed dataloader

This commit is contained in:
lucasdelimanogueira 2024-05-27 15:09:07 -03:00
parent e3bb882d3c
commit 240e603c0c

View file

@ -9,7 +9,7 @@ from norch.norchvision import transforms as norch_transforms
from torchvision import transforms as torch_transforms from torchvision import transforms as torch_transforms
class TestDistributed(unittest.TestCase): class TestDistributed(unittest.TestCase):
"""def test_distributed_sampler_batch_1(self): def test_distributed_sampler_batch_1(self):
transforms = norch_transforms.Compose( transforms = norch_transforms.Compose(
[ [
norch_transforms.ToTensor(), norch_transforms.ToTensor(),
@ -48,7 +48,7 @@ class TestDistributed(unittest.TestCase):
break break
for label_norch, label_torch in zip(labels_norch, labels_torch): for label_norch, label_torch in zip(labels_norch, labels_torch):
self.assertTrue(utils.compare_torch(label_norch, label_torch))""" self.assertTrue(utils.compare_torch(label_norch, label_torch))
def test_distributed_sampler_batch_32_rank_2(self): def test_distributed_sampler_batch_32_rank_2(self):