Add workaround for broken pika which cannot handle long-running connections.
authorRichard W.M. Jones <rjones@redhat.com>
Fri, 7 Jul 2017 12:08:11 +0000 (13:08 +0100)
committerRichard W.M. Jones <rjones@redhat.com>
Fri, 7 Jul 2017 12:08:11 +0000 (13:08 +0100)
perform-tests.py

index 2f9eb8b..b8c6079 100755 (executable)
@@ -25,8 +25,10 @@ import tempfile
 
 import config
 
+# Because tests are very long running, turn off heartbeats.
+# https://stackoverflow.com/questions/14572020/handling-long-running-tasks-in-pika-rabbitmq
 connection = pika.BlockingConnection(pika.ConnectionParameters(
-    host = config.mq_server))
+    host = config.mq_server, heartbeat_interval=0))
 channel = connection.channel()
 
 def ack(method):