Thanks for the report.  Can I ask how you installed zmq/pyzmq?<div><br></div><div>What is the output of:</div><div><br></div><div>zmq.zmq_version()</div><div>zmq.pyzmq_version()</div><div><br></div><div>?</div><div><br></div>

<div>By any chance, are you using EPD 7?</div><div><br></div><div>I'll have to find a Windows machine and do some digging around.</div><div><br></div><div>-MinRK</div><div><br><div class="gmail_quote">On Mon, Apr 11, 2011 at 13:24, Dave Hirschfeld <span dir="ltr"><<a href="mailto:dave.hirschfeld@gmail.com">dave.hirschfeld@gmail.com</a>></span> wrote:<br>

<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">I did some testing of the parallel code, but ran into the same problem as:<br>
<br>
<a href="http://article.gmane.org/gmane.comp.python.ipython.user/5616" target="_blank">http://article.gmane.org/gmane.comp.python.ipython.user/5616</a><br>
<br>
C:\dev\code>python C:\dev\bin\Python26\Scripts\ipcluster start -n 4<br>
[IPClusterApp] Using existing cluster dir:<br>
C:\Users\dhirschfeld\.ipython\cluster_default<br>
[IPClusterApp] Cluster directory set to:<br>
C:\Users\dhirschfeld\.ipython\cluster_default<br>
[IPClusterApp] Starting ipcluster with [daemon=False]<br>
[IPClusterApp] Creating pid file:<br>
C:\Users\dhirschfeld\.ipython\cluster_default\pid\ipcluster.pid<br>
[IPClusterApp] Starting LocalControllerLauncher: ['C:\\dev\\bin\\Python26<br>
\\python.exe', '-u', u'C:\\dev\\bin\\Python26\\lib\\site-packages\\IPython<br>
\\parallel\\apps\\ipcontrollerapp.py', '--log-to-file', '--log-level', '20',<br>
'--cluster-dir', u'C:\\Users\\dhirschfeld\\.ipython\\cluster_default']<br>
[IPClusterApp] Process 'C:\\dev\\bin\\Python26\\python.exe' started: 7096<br>
[IPClusterApp] IPython cluster: started<br>
Assertion failed: Socket operation on non-socket (..\..\..\src\zmq.cpp:632)<br>
<br>
I sent an email to the Users list but it appears to have gotten lost. So I've<br>
reproduced it below:<br>
<br>
<br>
Starting the controller and engines seperately appeared to work:<br>
<br>
c:\dev\code>python C:\dev\bin\Python26\Scripts\ipcontroller<br>
[IPControllerApp] Using existing cluster dir:<br>
C:\Users\dhirschfeld\.ipython\cluster_default<br>
[IPControllerApp] Cluster directory set to:<br>
C:\Users\dhirschfeld\.ipython\cluster_default<br>
[IPControllerApp] Hub listening on tcp://<a href="http://127.0.0.1:57543" target="_blank">127.0.0.1:57543</a> for registration.<br>
[IPControllerApp] Hub using DB backend:<br>
'IPython.parallel.controller.dictdb.DictDB'<br>
[IPControllerApp] hub::created hub<br>
[IPControllerApp] task::using Python leastload Task scheduler<br>
[IPControllerApp] Heartmonitor started<br>
[IPControllerApp] Creating pid file:<br>
C:\Users\dhirschfeld\.ipython\cluster_default\pid\ipcontroller.pid<br>
tcp://<a href="http://127.0.0.1:57564" target="_blank">127.0.0.1:57564</a><br>
tcp://<a href="http://127.0.0.1:57565" target="_blank">127.0.0.1:57565</a><br>
tcp://<a href="http://127.0.0.1:57544" target="_blank">127.0.0.1:57544</a><br>
tcp://<a href="http://127.0.0.1:57557" target="_blank">127.0.0.1:57557</a><br>
Scheduler started...<br>
<IPython.parallel.controller.scheduler.TaskScheduler object at 0x029C4E10><br>
<br>
<br>
c:\dev\code>python C:\dev\bin\Python26\Scripts\ipengine<br>
[IPEngineApp] Using existing cluster dir:<br>
C:\Users\dhirschfeld\.ipython\cluster_default<br>
[IPEngineApp] Cluster directory set to:<br>
C:\Users\dhirschfeld\.ipython\cluster_default<br>
[IPEngineApp] registering<br>
[IPEngineApp] Completed registration with id 0<br>
<br>
...<br>
<br>
In IPython I can connect to the engines but any attempt to do any calculation<br>
results in each engine dying with the error<br>
"Assertion failed: Invalid argument (..\..\..\src\zmq.cpp:632)" in the console.<br>
<br>
<br>
from IPython.parallel import Client<br>
<br>
rc = Client()<br>
<br>
rc.ids<br>
Out[3]: [0, 1]<br>
<br>
dview = rc[:]<br>
<br>
parallel_result = dview.map_sync(lambda x: x**10, range(32))<br>
---------------------------------------------------------------------------<br>
CompositeError                            Traceback (most recent call last)<br>
C:\dev\bin\Python26\Scripts\<ipython-input-5-678d85c014d0> in <module>()<br>
----> 1 parallel_result = dview.map_sync(lambda x: x**10, range(32))<br>
<br>
C:\dev\bin\Python26\lib\site-packages\IPython\parallel\client\view.pyc<br>
in map_sync(self, f, *sequences, **kwargs)<br>
    336             raise TypeError("map_sync doesn't take a `block` keyword<br>
                                     argument.")<br>
    337         kwargs['block'] = True<br>
--> 338         return self.map(f,*sequences,**kwargs)<br>
    339<br>
    340     def imap(self, f, *sequences, **kwargs):<br>
<br>
C:\dev\bin\Python26\Scripts\<string> in map(self, f, *sequences, **kwargs)<br>
<br>
C:\dev\bin\Python26\lib\site-packages\IPython\parallel\client\view.pyc<br>
in spin_after(f, self, *args, **kwargs)<br>
     62 def spin_after(f, self, *args, **kwargs):<br>
     63     """call spin after the method."""<br>
---> 64     ret = f(self, *args, **kwargs)<br>
     65     self.spin()<br>
     66     return ret<br>
<br>
C:\dev\bin\Python26\lib\site-packages\IPython\parallel\client\view.pyc<br>
in map(self, f, *sequences, **kwargs)<br>
    571         assert len(sequences) > 0,<br>
                        "must have some sequences to map onto!"<br>
    572         pf = ParallelFunction(self, f, block=block, **kwargs)<br>
--> 573         return pf.map(*sequences)<br>
    574<br>
    575     def execute(self, code, targets=None, block=None):<br>
<br>
C:\dev\bin\Python26\lib\site-packages\IPython\parallel\client\remotefunction.pyc<br>
in map(self, *sequences)<br>
    193         self._map = True<br>
    194         try:<br>
--> 195             ret = self.__call__(*sequences)<br>
    196         finally:<br>
    197             del self._map<br>
<br>
C:\dev\bin\Python26\lib\site-packages\IPython\parallel\client\remotefunction.pyc<br>
in __call__(self, *sequences)<br>
    179         if self.block:<br>
    180             try:<br>
--> 181                 return r.get()<br>
    182             except KeyboardInterrupt:<br>
    183                 return r<br>
<br>
C:\dev\bin\Python26\lib\site-packages\IPython\parallel\client\asyncresult.pyc<br>
in get(self, timeout)<br>
     96                 return self._result<br>
     97             else:<br>
---> 98                 raise self._exception<br>
     99         else:<br>
    100             raise error.TimeoutError("Result not ready.")<br>
<br>
CompositeError: one or more exceptions from call to method: <lambda><br>
[Engine Exception]EngineError: Engine 0 died while running task<br>
'c89ab757-1db6-4976-a7aa-86b859fe8f4f'<br>
[Engine Exception]EngineError: Engine 1 died while running task<br>
'436ffdf6-c082-45e0-a7f1-b09c10c74fe4'<br>
<br>
<br>
NB: pyzmq tests seem to pass except for the one below which seems like it's<br>
getting tripped up ove a deprecation warning.<br>
<br>
C:\dev\bin\Python26\Lib\site-packages\zmq\tests>nosetests --pdb-failures<br>
................................S...............................><br>
c:\dev\bin\python26\lib\site-packages\zmq\tests\__init__.py(104)<br>
assertRaisesErrno() -> got '%s'" % (zmq.ZMQError(errno), zmq.ZMQError(e.errno)))<br>
(Pdb) print e.message<br>
C:\dev\bin\Python26\Lib\site-packages\zmq\tests\__init__.py:1:<br>
DeprecationWarning: BaseException.message has been deprecated as of Python 2.6<br>
(Pdb) exit<br>
F........<br>
======================================================================<br>
FAIL: test_create (zmq.tests.test_socket.TestSocket)<br>
----------------------------------------------------------------------<br>
Traceback (most recent call last):<br>
  File "C:\dev\bin\Python26\Lib\site-packages\zmq\tests\test_socket.py", line<br>
47, in test_create<br>
    self.assertRaisesErrno(zmq.EPROTONOSUPPORT, s.bind, 'ftl://a')<br>
  File "C:\dev\bin\Python26\Lib\site-packages\zmq\tests\__init__.py", line 104,<br>
in assertRaisesErrno<br>
    got '%s'" % (zmq.ZMQError(errno), zmq.ZMQError(e.errno)))<br>
AssertionError: wrong error raised, expected 'Unknown error' got 'Protocol not<br>
supported'<br>
<br>
----------------------------------------------------------------------<br>
Ran 73 tests in 29.960s<br>
<br>
FAILED (SKIP=1, failures=1)<br>
<br>
HTH,<br>
<div><div></div><div class="h5">Dave<br>
<br>
<br>
<br>
<br>
<br>
<br>
<br>
_______________________________________________<br>
IPython-dev mailing list<br>
<a href="mailto:IPython-dev@scipy.org">IPython-dev@scipy.org</a><br>
<a href="http://mail.scipy.org/mailman/listinfo/ipython-dev" target="_blank">http://mail.scipy.org/mailman/listinfo/ipython-dev</a><br>
</div></div></blockquote></div><br></div>