from IPython import parallel
rc = parallel.Client()
dv = rc[:]
rc.ids

%px a=5

%px print a

%px a

with dv.sync_imports():
    import sys

%px from __future__ import print_function
%px print("ERROR", file=sys.stderr)

%pxconfig --noblock

%px import time
%px time.sleep(5)
%px time.time()

%pxresult

%%px
%matplotlib inline
import numpy as np
import matplotlib.pyplot as plt

dv.scatter('id', dv.targets, flatten=True)
dv['stride'] = len(dv)

%%px --block
print("    id=%s" % id)
print("stride=%s" % stride)

%%px --noblock
x = np.linspace(0,np.pi,1000)
for n in range(id, 12, stride):
    print(n)
    plt.plot(x,np.sin(n*x))
plt.title("Plot %i" % id);

%pxresult

%%px
from numpy.random import random
A = random((100,100,'invalid shape'))

%%px
%%bash
echo "remote parallel interactive bash!"
hostname
date
echo $$

%%px
%%ruby
puts 'hello from ruby'

dv.scatter('rank', dv.targets, flatten=True)

%%px
%%timeit
from numpy.random import random
from numpy.linalg import norm
N = 100 * (rank + 1)
A = random((N,N))
norm(A, 2)    

%%px
from IPython.parallel import bind_kernel
bind_kernel()

%%px

def foo(a, b):
    return a/(1-b)

def bar(b):
    return foo(2, b)

bar(1)

%px %qtconsole