Update return for all ranks
This commit is contained in:
@@ -15,7 +15,6 @@ def eval_tn_MPI(qibo_circ, datatype):
|
|||||||
ncpu_threads = multiprocessing.cpu_count() // 2
|
ncpu_threads = multiprocessing.cpu_count() // 2
|
||||||
n_samples = 8
|
n_samples = 8
|
||||||
|
|
||||||
root = 0
|
|
||||||
comm = MPI.COMM_WORLD
|
comm = MPI.COMM_WORLD
|
||||||
rank = comm.Get_rank()
|
rank = comm.Get_rank()
|
||||||
device_id = rank % getDeviceCount()
|
device_id = rank % getDeviceCount()
|
||||||
@@ -37,8 +36,7 @@ def eval_tn_MPI(qibo_circ, datatype):
|
|||||||
|
|
||||||
cutn.destroy(handle)
|
cutn.destroy(handle)
|
||||||
|
|
||||||
if rank == root:
|
return result, rank
|
||||||
return result, rank
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
|
|||||||
Reference in New Issue
Block a user