Skip to content

Commit 12455f5

Browse files
committed
misc: fix pr issues
1 parent 32e687d commit 12455f5

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

checkpoint_engine/ps.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -643,17 +643,16 @@ def _assign_receiver_ranks(
643643
assigned_cnt = 0
644644
while assigned_cnt < len(flattened_buckets):
645645
occupied_devices = set()
646-
for j in range(len(receiver_list)):
646+
for receiver_rank in receiver_list:
647647
if assigned_cnt >= len(flattened_buckets):
648648
break
649649
owner_rank, bucket = flattened_buckets[assigned_cnt]
650650
rdma_device = rank_to_rdma_device[owner_rank]
651-
if rdma_device not in occupied_devices:
652-
buckets_with_receiver.append((receiver_list[j], owner_rank, bucket))
653-
occupied_devices.add(rdma_device)
654-
assigned_cnt += 1
655-
else:
651+
if rdma_device in occupied_devices:
656652
break
653+
buckets_with_receiver.append((receiver_rank, owner_rank, bucket))
654+
occupied_devices.add(rdma_device)
655+
assigned_cnt += 1
657656

658657
return buckets_with_receiver
659658

0 commit comments

Comments
 (0)