from IPython.parallel import Client

c = Client(profile='mpi')

view = c[:]

view.activate() # enable magics

view.run('psum.py') # the script runs on all processes

view.scatter('a', np.arange(16)) # this array is scattered across processes

%px totalsum = psum(a) # psum is executed on all processes

view['totalsum']