You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have a requirement to support Redis in cluster and non-cluster mode.
I have been researching adding Redis Cluster support to arq.
This is what I have done so far:
Add "cluster: bool = False" flag to RedisSettings
import RedisCluster
from redis.asyncio.cluster import RedisCluster
In cluster mode extend class ArqRedis from RedisCluster
class ArqRedis(RedisCluster)
This works and I am able to connect to a Redis cluster.
However, there are several issues with redis.asyncio.cluster.RedisCluster
It does not support the pipeline command with transactions
It does not support MULTI/EXEC
arq uses the above commands heavily for atomic access to jobs, job results, etc
Does anyone have any insights into this? Has anyone looked at cluster support in arq?
I looked at aioredis-cluster python client, and that too has the same missing transactions support
The text was updated successfully, but these errors were encountered:
I have a requirement to support Redis in cluster and non-cluster mode.
I have been researching adding Redis Cluster support to arq.
This is what I have done so far:
from redis.asyncio.cluster import RedisCluster
class ArqRedis(RedisCluster)
This works and I am able to connect to a Redis cluster.
However, there are several issues with redis.asyncio.cluster.RedisCluster
arq uses the above commands heavily for atomic access to jobs, job results, etc
Does anyone have any insights into this? Has anyone looked at cluster support in arq?
I looked at aioredis-cluster python client, and that too has the same missing transactions support
The text was updated successfully, but these errors were encountered: