In [1]:
import ipyparallel as ipp

rc = ipp.Cluster().start_and_connect_sync()
dv = rc[:]
rc.ids

Starting 16 engines with <class 'ipyparallel.cluster.launcher.LocalEngineSetLauncher'>

  0%|          | 0/16 [00:00<?, ?engine/s]
Out[1]:
[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15]
In [2]:
%%px
from mpi4py import MPI

comm = MPI.COMM_WORLD
rank = comm.Get_rank()
size = comm.Get_size()

print(f'Rank {rank} of {size}')

[stdout:11] Rank 0 of 1

[stdout:1] Rank 0 of 1

[stdout:2] Rank 0 of 1

[stdout:4] Rank 0 of 1

[stdout:13] Rank 0 of 1

[stdout:10] Rank 0 of 1

[stdout:3] Rank 0 of 1

[stdout:8] Rank 0 of 1

[stdout:7] Rank 0 of 1

[stdout:14] Rank 0 of 1

[stdout:12] Rank 0 of 1

[stdout:5] Rank 0 of 1

[stdout:15] Rank 0 of 1

[stdout:6] Rank 0 of 1

[stdout:9] Rank 0 of 1

[stdout:0] Rank 0 of 1
In [4]:
%%px -t :2
from mpi4py import MPI

comm = MPI.COMM_WORLD
rank = comm.Get_rank()
size = comm.Get_size()

print(f'Rank {rank} of {size}')

[stdout:1] Rank 0 of 1

[stdout:0] Rank 0 of 1