clevermicro/amq-adapter-python
14
0
Fork 0
Code Issues 16 Pull Requests 4 Actions Packages Projects Releases Wiki Activity

fix: correct consul_initial_retry_delay configuration logic

Browse Source 
Co-authored-by: aider (openrouter/openai/o3-mini-high) <aider@aider.chat>
This commit is contained in:
Stanislav Hejny
2025-07-12 10:45:46 +01:00
parent 5d8f07be3c
commit dd590a11b5
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
amqp/config/amq_configuration.py
+11 -4
View File
@@ -82,10 +82,17 @@ class AMQAdapter:
self.PREFIX + "consul-max-retries", self.PREFIX + "consul-max-retries",
fallback=5 fallback=5
) )
self.consul_max_retries = config.getfloat( self.consul_initial_retry_delay = float(os.getenv(
"CleverMicro-AMQ", self.PREFIX + "consul-initial-retry-delay", "CONSUL_INITIAL_RETRY_DELAY",
fallback=float(os.getenv("CONSUL_INITIAL_RETRY_DELAY")) config.get(
if os.getenv("CONSUL_INITIAL_RETRY_DELAY") is not None else 0.2, "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: def adapter_prefix(self) -> str: