##// END OF EJS Templates
Backport PR #2126: ipcluster broken with any batch (PBS/LSF/SGE)...
Backport PR #2126: ipcluster broken with any batch (PBS/LSF/SGE) I have setup ipcluster_config.py to start with LSF: ``` c.IPClusterStart.controller_launcher_class = 'LSF' c.IPClusterStart.engine_launcher_class = 'LSF' ``` But the ipcluster command fails to start the engines: ``` ipcluster start --profile=lsf -n 10 ``` The problem is fixed if I add quotes to the launch command string ```cmd``` in ```launcher.py```. ``` diff --git a/IPython/parallel/apps/launcher.py b/IPython/parallel/apps/launcher.py index e752d2a..6035303 100644 --- a/IPython/parallel/apps/launcher.py +++ b/IPython/parallel/apps/launcher.py @@ -73,7 +73,7 @@ WINDOWS = os.name == 'nt' # Paths to the kernel apps #----------------------------------------------------------------------------- -cmd = "from IPython.parallel.apps.%s import launch_new_instance; launch_new_instance()" +cmd = "\"from IPython.parallel.apps.%s import launch_new_instance; launch_new_instance()\"" ipcluster_cmd_argv = [sys.executable, "-c", cmd % "ipclusterapp"] ```

File last commit:

r7739:dff285da
r7995:061632b4
Show More
task1.ipynb
139 lines | 2.5 KiB | text/plain | TextLexer

Simple task farming example

In [1]:
from IPython.parallel import Client

A Client.load_balanced_view is used to get the object used for working with load balanced tasks.

In [2]:
rc = Client()
v = rc.load_balanced_view()

Set the variable d on all engines:

In [3]:
rc[:]['d'] = 30

Define a function that will be our task:

In [4]:
def task(a):
    return a, 10*d, a*10*d

Run the task once:

In [5]:
ar = v.apply(task, 5)

Print the results:

In [6]:
print "a, b, c: ", ar.get()
a, b, c:  [5, 300, 1500]
In [ ]: