diff --git a/new_experiment/worker.py b/new_experiment/worker.py index 25af3613d0dff9b5d554f2f96b78161fab2d3379..bdc90229b37d4a6d1e4df6382dda35a8139a7ff3 100644 --- a/new_experiment/worker.py +++ b/new_experiment/worker.py @@ -20,7 +20,7 @@ _RABBIT_URL = get_param('RABBIT_URL', def main(): parameters = pika.URLParameters(_RABBIT_URL) - parameters._heartbeat = 10000000 + parameters._heartbeat = 65535 connection = pika.BlockingConnection(parameters=parameters) channel = connection.channel() channel.basic_qos(prefetch_count=1)