We have been using pika in a production system for approximately 6 months - we are running on ephemeral EMR clusters and when a new cluster starts it gets the latest version using easy_install - today we started getting the 1.0.0b1 release and basic connection functionality stopped working - for now we're going to hard code getting version 0.11.2 but needless to say we're less than happy with this result.
Connecting to amqp://xxxxxxxxxxxxxx@xxxxxxxxxxxx:5672/%2F?heartbeat_interval=30
Exception in thread Thread-1:
Traceback (most recent call last):
File "/usr/lib64/python2.7/threading.py", line 804, in __bootstrap_inner
self.run()
File "/usr/lib64/python2.7/threading.py", line 757, in run
self.__target(*self.__args, **self.__kwargs)
File "dlp_builds_processor.py", line 194, in start_process_work_received_monitor
rmq_con.run()
File "/home/hadoop/dlp-spark/utils/rmq_comm.py", line 387, in run
self.open_connection()
File "/home/hadoop/dlp-spark/utils/rmq_comm.py", line 378, in open_connection
self._connection = self.connect()
File "/home/hadoop/dlp-spark/utils/rmq_comm.py", line 91, in connect
stop_ioloop_on_close=False)
TypeError: __init__() got an unexpected keyword argument 'stop_ioloop_on_close'