diff --git a/pyinfra/queue/queue_manager.py b/pyinfra/queue/queue_manager.py index c12be9f..c51ce70 100644 --- a/pyinfra/queue/queue_manager.py +++ b/pyinfra/queue/queue_manager.py @@ -21,7 +21,7 @@ def get_connection_params(config: Config) -> pika.ConnectionParameters: "host": config.rabbitmq_host, "port": config.rabbitmq_port, "credentials": credentials, - "heartbeat": config.rabbitmq_heartbeat, + "heartbeat": int(config.rabbitmq_heartbeat), } return pika.ConnectionParameters(**pika_connection_params)