%%html
from IPython import parallel
rc = parallel.Client()
rc.block = True
rc.ids
def mul(a,b):
return a*b
def summary():
"""summarize some info about this process"""
import os
import socket
import sys
return {
'cwd': os.getcwd(),
'Python': sys.version,
'hostname': socket.gethostname(),
'pid': os.getpid(),
}
mul(5,6)
summary()
rc[0].apply(mul, 5, 6)
rc[0].apply(summary)
rc[:].apply(mul, 5, 6)
rc[:].apply(summary)
map(mul, range(1,10), range(2,11))
view = rc.load_balanced_view()
view.map(mul, range(1,10), range(2,11))
%%px
import os, socket
print os.getpid()
print socket.gethostname()