Merge branch 'master' of github.com:redis/redis-py into 7.0

Author: vladvildanov

.github/wordlist.txt

@@ -1,7 +1,9 @@
 APM
 ARGV
 BFCommands
+balancer
 CacheImpl
+cancelling
 CAS
 CFCommands
 CMSCommands
@@ -10,19 +12,32 @@ ClusterNodes
 ClusterPipeline
 ClusterPubSub
 ConnectionPool
+config
 CoreCommands
+DatabaseConfig
+DNS
+EchoHealthCheck
 EVAL
 EVALSHA
+failover
+FQDN
 Grokzen's
+Healthcheck
+HealthCheckPolicies
+healthcheck
+healthchecks
 INCR
 IOError
 Instrumentations
 JSONCommands
 Jaeger
 Ludovico
 Magnocavallo
+MultiDbConfig
+MultiDBClient
 McCurdy
 NOSCRIPT
+NoValidDatabaseException
 NUMPAT
 NUMPT
 NUMSUB
@@ -43,6 +58,7 @@ RedisInstrumentor
 RedisJSON
 RedisTimeSeries
 SHA
+SLA
 SearchCommands
 SentinelCommands
 SentinelConnectionPool
@@ -52,6 +68,8 @@ SpanKind
 Specfiying
 StatusCode
 TCP
+TemporaryUnavailableException
+TLS
 TOPKCommands
 TimeSeriesCommands
 Uptrace
@@ -91,6 +109,7 @@ json
 keyslot
 keyspace
 kwarg
+kwargs
 linters
 localhost
 lua

.github/workflows/docs.yaml

@@ -26,7 +26,7 @@ jobs:
      runs-on: ubuntu-latest
      steps:
        - uses: actions/checkout@v5
-       - uses: actions/setup-python@v5
+       - uses: actions/setup-python@v6
          with:
            python-version: 3.9
            cache: 'pip'

.github/workflows/install_and_test.sh

@@ -40,11 +40,12 @@ cd ${TESTDIR}
 # install, run tests
 pip install ${PKG}
 # Redis tests
-pytest -m 'not onlycluster' --ignore=tests/test_scenario
+pytest -m 'not onlycluster' --ignore=tests/test_scenario --ignore=tests/test_asyncio/test_scenario
 # RedisCluster tests
 CLUSTER_URL="redis://localhost:16379/0"
 CLUSTER_SSL_URL="rediss://localhost:27379/0"
 pytest -m 'not onlynoncluster and not redismod and not ssl' \
   --ignore=tests/test_scenario \
+  --ignore=tests/test_asyncio/test_scenario \
   --redis-url="${CLUSTER_URL}" \
   --redis-ssl-url="${CLUSTER_SSL_URL}"

.github/workflows/integration.yaml

@@ -27,6 +27,8 @@ env:
   CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
   # this speeds up coverage with Python 3.12: https://github.com/nedbat/coveragepy/issues/1665
   COVERAGE_CORE: sysmon
+  # patch releases get included in the base version image when they are published
+  # for example after 8.2.1 is published, 8.2 image contains 8.2.1 content
   CURRENT_CLIENT_LIBS_TEST_STACK_IMAGE_TAG: '8.2'
   CURRENT_REDIS_VERSION: '8.2'
 
@@ -47,7 +49,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v5
-      - uses: actions/setup-python@v5
+      - uses: actions/setup-python@v6
         with:
           python-version: 3.9
           cache: 'pip'
@@ -74,7 +76,7 @@ jobs:
       max-parallel: 15
       fail-fast: false
       matrix:
-        redis-version: ['8.2.1-pre', '${{ needs.redis_version.outputs.CURRENT }}', '8.0.2' ,'7.4.4', '7.2.9']
+        redis-version: ['8.4-M01-pre', '${{ needs.redis_version.outputs.CURRENT }}', '8.0.2' ,'7.4.4', '7.2.9']
         python-version: ['3.9', '3.13']
         parser-backend: ['plain']
         event-loop: ['asyncio']
@@ -175,7 +177,7 @@ jobs:
         extension: ['tar.gz', 'whl']
     steps:
       - uses: actions/checkout@v5
-      - uses: actions/setup-python@v5
+      - uses: actions/setup-python@v6
         with:
           python-version: 3.9
       - name: Run installed unit tests
@@ -194,7 +196,7 @@ jobs:
         python-version: ['3.9', '3.10', '3.11', '3.12', '3.13', 'pypy-3.9', 'pypy-3.10']
     steps:
       - uses: actions/checkout@v5
-      - uses: actions/setup-python@v5
+      - uses: actions/setup-python@v6
         with:
           python-version: ${{ matrix.python-version }}
           cache: 'pip'

.github/workflows/pypi-publish.yaml

@@ -15,7 +15,7 @@ jobs:
     steps:
       - uses: actions/checkout@v5
       - name: install python
-        uses: actions/setup-python@v5
+        uses: actions/setup-python@v6
         with:
           python-version: 3.9
       - run: pip install build twine

.github/workflows/spellcheck.yml

@@ -8,7 +8,7 @@ jobs:
       - name: Checkout
         uses: actions/checkout@v5
       - name: Check Spelling
-        uses: rojopolis/spellcheck-github-actions@0.51.0
+        uses: rojopolis/spellcheck-github-actions@0.52.0
         with:
           config_path: .github/spellcheck-settings.yml
           task_name: Markdown

.github/workflows/stale-issues.yml

@@ -20,7 +20,7 @@ jobs:
     steps:
       # First step: Handle regular issues (excluding needs-information)
       - name: Mark regular issues as stale
-        uses: actions/stale@v9
+        uses: actions/stale@v10
         with:
           repo-token: ${{ secrets.GITHUB_TOKEN }}
 
@@ -64,7 +64,7 @@ jobs:
 
       # Second step: Handle needs-information issues with accelerated timeline
       - name: Mark needs-information issues as stale
-        uses: actions/stale@v9
+        uses: actions/stale@v10
         with:
           repo-token: ${{ secrets.GITHUB_TOKEN }}
 

dev_requirements.txt

@@ -14,3 +14,4 @@ uvloop
 vulture>=2.3.0
 numpy>=1.24.0
 redis-entraid==1.0.0
+pybreaker>=1.4.0

docs/examples/pipeline_examples.ipynb

@@ -156,6 +156,67 @@
     "pipe.set(\"a\", \"a value\").set(\"b\", \"b value\").get(\"a\").execute()"
    ]
   },
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": [
+    "Here's a slightly more advanced example for chaining complex operations using the builder pattern."
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "from dataclasses import dataclass\n",
+    "from typing import Optional\n",
+    "\n",
+    "@dataclass\n",
+    "class User:\n",
+    "    email: str\n",
+    "    username: Optional[str] = None\n",
+    "\n",
+    "@dataclass\n",
+    "class Post:\n",
+    "    title: str\n",
+    "    body: str\n",
+    "    author: Optional[str] = None\n",
+    "\n",
+    "class RedisRepository:\n",
+    "    def __init__(self):\n",
+    "        self.pipeline = r.pipeline()\n",
+    "\n",
+    "    def add_user(self, user: User):\n",
+    "        if not user.username:\n",
+    "            user.username = user.email.split(\"@\")[0]\n",
+    "        self.pipeline.hset(f\"user:{user.username}\", mapping={\"username\": user.username, \"email\": user.email})\n",
+    "        return self\n",
+    "    \n",
+    "    def add_post(self, post: Post):\n",
+    "        self.pipeline.hset(f\"post:#{post.title}#\", mapping={\"title\": post.title, \"body\": post.body, \"author\": post.author})\n",
+    "        if post.author:\n",
+    "            self.pipeline.sadd(f\"user:{post.author}:posts\", f\"post:#{post.title}#\")\n",
+    "        return self\n",
+    "\n",
+    "    def add_follow(self, follower: str, following: str):\n",
+    "        self.pipeline.sadd(f\"user:{follower}:following\", following)\n",
+    "        self.pipeline.sadd(f\"user:{following}:followers\", follower)\n",
+    "        return self\n",
+    "\n",
+    "    def execute(self):\n",
+    "        return self.pipeline.execute()\n",
+    "\n",
+    "pipe = RedisRepository()\n",
+    "results = (pipe\n",
+    "    .add_user(User(email=\"[email protected]\"))\n",
+    "    .add_user(User(email=\"[email protected]\"))\n",
+    "    .add_follow(\"alice\", \"bob\")\n",
+    "    .add_post(Post(title=\"Hello World\", body=\"I'm using Redis!\", author=\"alice\"))\n",
+    "    .execute()\n",
+    ")"
+   ]
+  },
   {
    "cell_type": "markdown",
    "metadata": {},