<div dir="ltr">I am trying to run python multiprocessing to execute a remote function that I call with the help of celery. My program runs  ok if I just run one process. But when I run more than one process, I get the error below. Is it because of incompatible versions in python plugins and rabbitmq?<div><div><br></div><div><div>Process Process-1:</div><div>Traceback (most recent call last):</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap</div><div>    self.run()</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 114, in run</div><div>    self._target(*self._args, **self._kwargs)</div><div>  File "testHello.py", line 16, in test_hello_aux</div><div>    print output.get()</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/result.py", line 169, in get</div><div>    no_ack=no_ack,</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 155, in wait_for</div><div>    on_interval=on_interval)</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 229, in consume</div><div>    no_ack=no_ack, accept=self.accept) as consumer:</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 359, in __init__</div><div>    self.revive(self.channel)</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 371, in revive</div><div>    self.declare()</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 381, in declare</div><div>    queue.declare()</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 505, in declare</div><div>    self.queue_declare(nowait, passive=False)</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 531, in queue_declare</div><div>    nowait=nowait)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/channel.py", line 1254, in queue_declare</div><div>    self._send_method((50, 10), args)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 56, in _send_method</div><div>    self.channel_id, method_sig, args, content,</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/method_framing.py", line 221, in write_method</div><div>    write_frame(1, channel, payload)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/transport.py", line 177, in write_frame</div><div>    frame_type, channel, size, payload, 0xce,</div><div>  File "/usr/lib/python2.7/socket.py", line 224, in meth</div><div>    return getattr(self._sock,name)(*args)</div><div>error: [Errno 32] Broken pipe</div><div>Process Process-2:</div><div>Traceback (most recent call last):</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap</div><div>    self.run()</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 114, in run</div><div>    self._target(*self._args, **self._kwargs)</div><div>  File "testHello.py", line 16, in test_hello_aux</div><div>    print output.get()</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/result.py", line 169, in get</div><div>    no_ack=no_ack,</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 155, in wait_for</div><div>    on_interval=on_interval)</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 229, in consume</div><div>    no_ack=no_ack, accept=self.accept) as consumer:</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 359, in __init__</div><div>Process Process-3:</div><div>    self.revive(self.channel)</div><div>Traceback (most recent call last):</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 371, in revive</div><div>    self.declare()</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 381, in declare</div><div>    queue.declare()</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 504, in declare</div><div>    self.run()</div><div>    self.exchange.declare(nowait)</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 114, in run</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 166, in declare</div><div>    self._target(*self._args, **self._kwargs)</div><div>    nowait=nowait, passive=passive,</div><div>  File "testHello.py", line 16, in test_hello_aux</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/channel.py", line 613, in exchange_declare</div><div>    print output.get()</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/result.py", line 169, in get</div><div>    no_ack=no_ack,</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 155, in wait_for</div><div>    on_interval=on_interval)</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 229, in consume</div><div>    no_ack=no_ack, accept=self.accept) as consumer:</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 359, in __init__</div><div>    self._send_method((40, 10), args)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 56, in _send_method</div><div>    self.channel_id, method_sig, args, content,</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/method_framing.py", line 221, in write_method</div><div>    self.revive(self.channel)</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 371, in revive</div><div>    self.declare()</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 381, in declare</div><div>    write_frame(1, channel, payload)</div><div>    queue.declare()</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/transport.py", line 177, in write_frame</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 504, in declare</div><div>    frame_type, channel, size, payload, 0xce,</div><div>  File "/usr/lib/python2.7/socket.py", line 224, in meth</div><div>    self.exchange.declare(nowait)</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 166, in declare</div><div>    nowait=nowait, passive=passive,</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/channel.py", line 620, in exchange_declare</div><div>    return getattr(self._sock,name)(*args)</div><div>error: [Errno 32] Broken pipe</div><div>    (40, 11),  # Channel.exchange_declare_ok</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 67, in wait</div><div>    self.channel_id, allowed_methods)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/connection.py", line 237, in _wait_method</div><div>    self.method_reader.read_method()</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/method_framing.py", line 189, in read_method</div><div>    raise m</div><div>error: [Errno 104] Connection reset by peer</div><div>Process Process-4:</div><div>Traceback (most recent call last):</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap</div><div>    self.run()</div><div>  File "/usr/lib/python2.7/multiprocessing/process.py", line 114, in run</div><div>    self._target(*self._args, **self._kwargs)</div><div>  File "testHello.py", line 16, in test_hello_aux</div><div>    print output.get()</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/result.py", line 169, in get</div><div>    no_ack=no_ack,</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 155, in wait_for</div><div>    on_interval=on_interval)</div><div>  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 229, in consume</div><div>    no_ack=no_ack, accept=self.accept) as consumer:</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 359, in __init__</div><div>    self.revive(self.channel)</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 371, in revive</div><div>    self.declare()</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 381, in declare</div><div>    queue.declare()</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 505, in declare</div><div>    self.queue_declare(nowait, passive=False)</div><div>  File "/usr/local/lib/python2.7/dist-packages/kombu/entity.py", line 531, in queue_declare</div><div>    nowait=nowait)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/channel.py", line 1258, in queue_declare</div><div>    (50, 11),  # Channel.queue_declare_ok</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 67, in wait</div><div>    self.channel_id, allowed_methods)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/connection.py", line 270, in _wait_method</div><div>    self.wait()</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 69, in wait</div><div>    return self.dispatch_method(method_sig, args, content)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 87, in dispatch_method</div><div>    return amqp_method(self, args)</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/connection.py", line 526, in _close</div><div>    (class_id, method_id), ConnectionError)</div><div>UnexpectedFrame: Basic.publish: (505) UNEXPECTED_FRAME - expected content header for class 60, got non content header frame instead</div></div><div><br></div></div></div>