We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 254007a + 5aef6f2 commit 594fa6aCopy full SHA for 594fa6a
HISTORY.rst
@@ -1,7 +1,7 @@
1
0.3.2 (unreleased)
2
------------------
3
4
-- Nothing changed yet.
+- Set Redis socket keepalive and retry on timeout for RPCRedisCommLayer.
5
6
7
0.3.1 (2025-04-14)
asyncio_rpc/commlayers/redis.py
@@ -36,7 +36,12 @@ async def create(
36
self.serialization = serialization
37
38
# Redis for publishing
39
- self.redis = async_redis.from_url(f"redis://{host}")
+ self.redis = async_redis.from_url(
40
+ f"redis://{host}",
41
+ socket_keepalive=True,
42
+ retry_on_timeout=True,
43
+ health_check_interval=None, # no health checks for Redis pub/sub
44
+ )
45
46
# By default register all RPC models
47
for model in SERIALIZABLE_MODELS:
0 commit comments