From dd590a11b564f688e10daa19d607c6dc9c065751 Mon Sep 17 00:00:00 2001 From: Stanislav Hejny Date: Sat, 12 Jul 2025 10:45:46 +0100 Subject: [PATCH] fix: correct consul_initial_retry_delay configuration logic Co-authored-by: aider (openrouter/openai/o3-mini-high) --- amqp/config/amq_configuration.py | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/amqp/config/amq_configuration.py b/amqp/config/amq_configuration.py index 612f7f7..9f33d6d 100644 --- a/amqp/config/amq_configuration.py +++ b/amqp/config/amq_configuration.py @@ -82,10 +82,17 @@ class AMQAdapter: self.PREFIX + "consul-max-retries", fallback=5 ) - self.consul_max_retries = config.getfloat( - "CleverMicro-AMQ", self.PREFIX + "consul-initial-retry-delay", - fallback=float(os.getenv("CONSUL_INITIAL_RETRY_DELAY")) - if os.getenv("CONSUL_INITIAL_RETRY_DELAY") is not None else 0.2, + self.consul_initial_retry_delay = float(os.getenv( + "CONSUL_INITIAL_RETRY_DELAY", + config.get( + "CleverMicro-AMQ", + self.PREFIX + "consul-initial-retry-delay", + fallback="0.2" + ) + )) if os.getenv("CONSUL_INITIAL_RETRY_DELAY") is not None else config.getfloat( + "CleverMicro-AMQ", + self.PREFIX + "consul-initial-retry-delay", + fallback=0.2 ) def adapter_prefix(self) -> str: