Added config reload handler mechanism, calls a Python method on config (#334)

This commit is contained in:
cybermaggedon 2025-04-02 00:23:30 +01:00 committed by GitHub
parent 88eae0a9f0
commit a2c64cad4a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 60 additions and 5 deletions

View file

@ -82,7 +82,7 @@ class Consumer(BaseProcessor):
while True:
msg = self.consumer.receive()
msg = await asyncio.to_thread(self.consumer.receive)
expiry = time.time() + self.rate_limit_timeout