RED-4653: Added explicit conversion of the heartbeat config value to an int before passing it to pika

2022-07-21 17:41:55 +02:00 · 2022-07-21 17:41:55 +02:00 · 4bf1a02345
commit 4bf1a02345
parent 8f2bc4e028
1 changed files with 1 additions and 1 deletions
--- 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)