Redis update 2021-10-08

.github/workflows/ci.yml

@@ -43,6 +43,7 @@ jobs:
       run: |
         pip install -r tests/requirements-mypy.txt
         mypy
+      continue-on-error: true
     - name: Run linter
       run: |
         make lint
@@ -60,14 +61,12 @@ jobs:
     strategy:
       matrix:
         os: [ubuntu-latest]
-        pyver: ["3.6", "3.7", "3.8", "3.9", "3.10", pypy3]
+        pyver: ["3.7", "3.8", "3.9", "3.10", "pypy-3.7", "pypy-3.8"]
         uvloop: [uvloop, no-uvloop]
-        redis: [5.0.10, 6.2.4]
+        redis: [6.2.4]
         exclude:
-        - { pyver: pypy3, uvloop: uvloop, os: ubuntu-latest, redis: 5.0.10 }
-        - { pyver: pypy3, uvloop: uvloop, os: ubuntu-latest, redis: 6.2.4 }
-        - { pyver: 3.6, uvloop: uvloop, os: ubuntu-latest, redis: 5.0.10 }
-        - { pyver: 3.6, uvloop: uvloop, os: ubuntu-latest, redis: 6.2.4 }
+        - { pyver: pypy-3.7, uvloop: uvloop, os: ubuntu-latest, redis: 6.2.4 }
+        - { pyver: pypy-3.8, uvloop: uvloop, os: ubuntu-latest, redis: 6.2.4 }
       fail-fast: false
     services:
       redis:
@@ -81,6 +80,15 @@ jobs:
           --health-interval 10s
           --health-timeout 5s
           --health-retries 5
+      redismod:
+        image: redislabs/redismod:edge
+        ports:
+        - 36379:6379/tcp
+        options: >-
+          --health-cmd "redis-cli ping"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
     runs-on: ${{ matrix.os }}
     timeout-minutes: 15
     env:

.pre-commit-config.yaml

@@ -47,7 +47,6 @@ repos:
   - id: check-xml
   - id: check-yaml
   - id: debug-statements
-  - id: check-added-large-files
   - id: check-symlinks
   - id: debug-statements
   - id: detect-aws-credentials

CHANGES/1156.feature

@@ -0,0 +1 @@
+Updates aioredis to redis at commit andymccurdy/redis-py@9419f1d

CONTRIBUTORS.txt

@@ -66,6 +66,7 @@ Stanislau Arkhipenka
 Taku Fukada
 Taras Voinarovskyi
 Thanos Lefteris
+Theron Luhn <luhn>
 Thomas Steinacher
 Volodymyr Hotsyk
 Youngmin Koo <youngminz>

README.md

@@ -20,7 +20,7 @@ based on asyncio.
 | ACL support                  | :white_check_mark:       |
 | Streams support              | :white_check_mark:       |
 | Redis Cluster support        | :no_entry_sign:          |
-| Tested Python versions       | 3.6, 3.7, 3.8, 3.9, 3.10 |
+| Tested Python versions       | 3.7, 3.8, 3.9, 3.10      |
 | Tested for Redis servers     | 5.0, 6.0                 |
 | Support for dev Redis server | through low-level API    |
 
@@ -37,7 +37,7 @@ Recommended with hiredis for performance and stability reasons:
 
 ## Requirements
 
--   Python 3.6+
+-   Python 3.7+
 -   hiredis (Optional but recommended)
 -   async-timeout
 -   typing-extensions

aioredis/__init__.py

@@ -31,7 +31,7 @@ def int_or_str(value):
         return value
 
 
-__version__ = "2.0.1"
+__version__ = "2.1.0"
 VERSION = tuple(map(int_or_str, __version__.split(".")))
 
 __all__ = [

aioredis/backoff.py

@@ -0,0 +1,105 @@
+import random
+from abc import ABC, abstractmethod
+
+
+class AbstractBackoff(ABC):
+    """Backoff interface"""
+
+    def reset(self):
+        """
+        Reset internal state before an operation.
+        `reset` is called once at the beginning of
+        every call to `Retry.call_with_retry`
+        """
+        pass
+
+    @abstractmethod
+    def compute(self, failures: int):
+        """Compute backoff in seconds upon failure"""
+        pass
+
+
+class ConstantBackoff(AbstractBackoff):
+    """Constant backoff upon failure"""
+
+    def __init__(self, backoff: float):
+        """`backoff`: backoff time in seconds"""
+        self._backoff = backoff
+
+    def compute(self, failures: int):
+        return self._backoff
+
+
+class NoBackoff(ConstantBackoff):
+    """No backoff upon failure"""
+
+    def __init__(self):
+        super().__init__(0)
+
+
+class ExponentialBackoff(AbstractBackoff):
+    """Exponential backoff upon failure"""
+
+    def __init__(self, cap: float, base: float):
+        """
+        `cap`: maximum backoff time in seconds
+        `base`: base backoff time in seconds
+        """
+        self._cap = cap
+        self._base = base
+
+    def compute(self, failures: int):
+        return min(self._cap, self._base * 2 ** failures)
+
+
+class FullJitterBackoff(AbstractBackoff):
+    """Full jitter backoff upon failure"""
+
+    def __init__(self, cap: float, base: float):
+        """
+        `cap`: maximum backoff time in seconds
+        `base`: base backoff time in seconds
+        """
+        self._cap = cap
+        self._base = base
+
+    def compute(self, failures: int):
+        return random.uniform(0, min(self._cap, self._base * 2 ** failures))
+
+
+class EqualJitterBackoff(AbstractBackoff):
+    """Equal jitter backoff upon failure"""
+
+    def __init__(self, cap: float, base: float):
+        """
+        `cap`: maximum backoff time in seconds
+        `base`: base backoff time in seconds
+        """
+        self._cap = cap
+        self._base = base
+
+    def compute(self, failures):
+        temp = min(self._cap, self._base * 2 ** failures) / 2
+        return temp + random.uniform(0, temp)
+
+
+class DecorrelatedJitterBackoff(AbstractBackoff):
+    """Decorrelated jitter backoff upon failure"""
+
+    def __init__(self, cap: float, base: float):
+        """
+        `cap`: maximum backoff time in seconds
+        `base`: base backoff time in seconds
+        """
+        self._cap = cap
+        self._base = base
+        self._previous_backoff = 0
+
+    def reset(self):
+        self._previous_backoff = 0
+
+    def compute(self, failures: int):
+        max_backoff = max(self._base, self._previous_backoff * 3)
+        temp = random.uniform(self._base, max_backoff)
+        self._previous_backoff = min(self._cap, temp)
+        return self._previous_backoff