In [3]:

    

from ipyparallel import Client
profile_dir = "/home/data/files/profile"
rc = Client(profile_dir=profile_dir)

print "Parallel process: {0} {1}".format(len(rc.ids), rc.ids)


    

    




Parallel process: 4

In [4]:

    

dview = rc.direct_view()
with dview.sync_imports():
    import os
    
    dview.block=True
    pids = dview.apply(os.getpid)
    dview.block=False
    ar = dview.apply(os.getpid)
    dview.wait(ar)
    pids = ar.get()
    print pids


    

    




importing os on engine(s)
importing __doc__ from posix on engine(s)
importing Again from zmq.error on engine(s)
importing strerror,zmq_errno from zmq.backend on engine(s)
[72, 73, 73, 67]

In [ ]: