bidule

wiremind · Jan 24, 2024 · dfa701e · dfa701e
1 parent cf8b5eb
commit dfa701e
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/remoulade/cancel/backends/redis.py b/remoulade/cancel/backends/redis.py
@@ -56,7 +56,7 @@ def __init__(
     ) -> None:
         super().__init__(cancellation_ttl=cancellation_ttl)
 
-        self.client = client or redis_client(url=url, parameters=parameters)
+        self.client = client or redis_client(url=url, **parameters)
         self.key = key
 
     def is_canceled(self, message_id: str, composition_id: Optional[str]) -> bool:

diff --git a/remoulade/rate_limits/backends/redis.py b/remoulade/rate_limits/backends/redis.py
@@ -37,7 +37,7 @@ class RedisBackend(RateLimiterBackend):
     """
 
     def __init__(self, *, client=None, url=None, **parameters):
-        self.client = client or redis_client(url=url, parameters=parameters)
+        self.client = client or redis_client(url=url, **parameters)
 
     def add(self, key: str, value: int, ttl: int) -> bool:
         return bool(self.client.set(key, value, px=ttl, nx=True))

diff --git a/remoulade/results/backends/redis.py b/remoulade/results/backends/redis.py
@@ -60,7 +60,7 @@ def __init__(
         super().__init__(namespace=namespace, encoder=encoder, default_timeout=default_timeout)
 
         url = url or os.getenv("REMOULADE_REDIS_URL")
-        self.client = client or redis_client(url=url, parameters=parameters)
+        self.client = client or redis_client(url=url, **parameters)
         self.max_retries = max_retries
         self.min_backoff = min_backoff
         self.max_backoff = max_backoff

diff --git a/remoulade/state/backends/redis.py b/remoulade/state/backends/redis.py
@@ -24,7 +24,7 @@ class RedisBackend(StateBackend):
 
     def __init__(self, *, namespace="remoulade-state", encoder=None, client=None, url=None, **parameters):
         super().__init__(namespace=namespace, encoder=encoder)
-        self.client = client or redis_client(url=url, parameters=parameters)
+        self.client = client or redis_client(url=url, **parameters)
 
     def get_state(self, message_id):
         key = self._build_message_key(message_id)