[IPython-user] Fwd: TaskClient problems

[Fernando Perez]

Hey Mike,

On Thu, Apr 2, 2009 at 2:54 PM, M Trumpis <mtrumpis@berkeley.edu> wrote:
> I'll try and see on Mac OS, but I do see the same thing in Ubuntu with
> twisted 8.1.0

Weird, here's a transcript of my ipcluster session:

uqbar[~]> ipcluster local
2009-04-02 15:19:17-0700 [-] Log opened.
2009-04-02 15:19:17-0700 [-] Process ['ipcontroller',
'--logfile=/home/fperez/.ipython/log/ipcontroller'] has started with
pid=30471
2009-04-02 15:19:18-0700 [-] Process ['ipengine',
'--logfile=/home/fperez/.ipython/log/ipengine30471-'] has started with
pid=30477
2009-04-02 15:19:18-0700 [-] Process ['ipengine',
'--logfile=/home/fperez/.ipython/log/ipengine30471-'] has started with
pid=30479
2009-04-02 15:19:18-0700 [-] Engines started with pids: [30477, 30479]
^C2009-04-02 15:20:34-0700 [-] Stopping local cluster
2009-04-02 15:20:34-0700 [-] Process ['ipengine',
'--logfile=/home/fperez/.ipython/log/ipengine30471-'] has stopped with
0
2009-04-02 15:20:34-0700 [-] Process ['ipcontroller',
'--logfile=/home/fperez/.ipython/log/ipcontroller'] has stopped with 0
2009-04-02 15:20:34-0700 [-] Process ['ipengine',
'--logfile=/home/fperez/.ipython/log/ipengine30471-'] has stopped with
0
2009-04-02 15:20:34-0700 [-] Engines received signal: [0, 0]
2009-04-02 15:20:35-0700 [-] Main loop terminated.
uqbar[~]>


And all the while, I ran this code in ipython using those engines:

In [1]: from IPython.kernel  import client

In [2]: mec = client.MultiEngineClient()

In [3]: mec.get_ids()
Out[3]: [0, 1]

In [4]: mec.execute('print 1')
Out[4]:
<Results List>
[0] In [1]: print 1
[0] Out[1]: 1

[1] In [1]: print 1
[1] Out[1]: 1


In [7]: mec.push(dict(x=1))
Out[7]: [None, None]

In [9]: mec.activate()

In [10]: autopx
Auto Parallel Enabled
Type %autopx to disable

In [11]: import numpy as np
<Results List>
[0] In [2]: import numpy as np
[1] In [2]: import numpy as np


In [12]: x=np.random.rand()
<Results List>
[0] In [3]: x=np.random.rand()
[1] In [3]: x=np.random.rand()


In [13]: autopx
Auto Parallel Disabled

In [14]: mec.pull('x')
Out[14]: [0.75263160660663864, 0.39351421449252755]

In [15]:
uqbar[~]>


I only edited above commands where I made typos or was using help, but
that's an actual session on my box.  Can you reproduce this?

Cheers,

f