mirror of
https://github.com/mailcow/mailcow-dockerized.git
synced 2025-07-17 00:01:18 -04:00
Compare commits
3 Commits
30e241babe
...
9ba5c13702
Author | SHA1 | Date | |
---|---|---|---|
|
9ba5c13702 | ||
|
930473a980 | ||
|
533bd36572 |
@ -198,8 +198,8 @@ async def handle_pubsub_messages(channel: aioredis.client.PubSub):
|
||||
|
||||
while True:
|
||||
try:
|
||||
async with async_timeout.timeout(1):
|
||||
message = await channel.get_message(ignore_subscribe_messages=True)
|
||||
async with async_timeout.timeout(60):
|
||||
message = await channel.get_message(ignore_subscribe_messages=True, timeout=30)
|
||||
if message is not None:
|
||||
# Parse message
|
||||
data_json = json.loads(message['data'].decode('utf-8'))
|
||||
@ -244,7 +244,7 @@ async def handle_pubsub_messages(channel: aioredis.client.PubSub):
|
||||
else:
|
||||
dockerapi.logger.error("Unknwon PubSub recieved - %s" % json.dumps(data_json))
|
||||
|
||||
await asyncio.sleep(0.01)
|
||||
await asyncio.sleep(0.0)
|
||||
except asyncio.TimeoutError:
|
||||
pass
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user