fix bugs to adapt to the new framework

pull/2240/merge
cuicheng01 2022-09-20 10:06:20 +00:00
parent d19b2712f1
commit 3bd78eb1d3
1 changed files with 2 additions and 1 deletions

View File

@ -81,7 +81,8 @@ def classification_eval(engine, epoch_id=0):
# gather Tensor when distributed
if paddle.distributed.get_world_size() > 1:
label_list = []
label = batch[1].cuda() if engine.config["Global"][
device_id = paddle.distributed.ParallelEnv().device_id
label = batch[1].cuda(device_id) if engine.config["Global"][
"device"] == "gpu" else batch[1]
paddle.distributed.all_gather(label_list, label)
labels = paddle.concat(label_list, 0)