Commit e3c57c82 authored by Neel Kant's avatar Neel Kant
Browse files

Fix samples mapping bug

parent bf599e86
...@@ -221,8 +221,8 @@ def get_block_samples_mapping(block_dataset, title_dataset, data_prefix, num_epo ...@@ -221,8 +221,8 @@ def get_block_samples_mapping(block_dataset, title_dataset, data_prefix, num_epo
# parallel case # parallel case
counts = torch.cuda.LongTensor([1]) counts = torch.cuda.LongTensor([1])
torch.distributed.all_reduce(counts, group=mpu.get_data_parallel_group()) torch.distributed.all_reduce(counts, group=mpu.get_data_parallel_group())
#assert counts[0].item() == torch.distributed.get_world_size( assert counts[0].item() == torch.distributed.get_world_size(
# group=mpu.get_data_parallel_group()) group=mpu.get_data_parallel_group())
# Load indexed dataset. # Load indexed dataset.
print_rank_0(' > loading indexed mapping from {}'.format( print_rank_0(' > loading indexed mapping from {}'.format(
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment