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

Author: vladvildanov

.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/integration.yaml

@@ -47,7 +47,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'
@@ -175,7 +175,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 +194,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/stale-issues.yml

@@ -1,25 +1,95 @@
-name: "Close stale issues"
+name: "Stale Issue Management"
 on:
   schedule:
-  - cron: "0 0 * * *"
+    # Run daily at midnight UTC
+    - cron: "0 0 * * *"
+  workflow_dispatch: # Allow manual triggering
+
+env:
+  # Default stale policy timeframes
+  DAYS_BEFORE_STALE: 365
+  DAYS_BEFORE_CLOSE: 30
+
+  # Accelerated timeline for needs-information issues
+  NEEDS_INFO_DAYS_BEFORE_STALE: 30
+  NEEDS_INFO_DAYS_BEFORE_CLOSE: 7
 
-permissions: {}
 jobs:
   stale:
-    permissions:
-      issues: write  #  to close stale issues (actions/stale)
-      pull-requests: write  #  to close stale PRs (actions/stale)
-
     runs-on: ubuntu-latest
     steps:
-    - uses: actions/stale@v9
-      with:
-        repo-token: ${{ secrets.GITHUB_TOKEN }}
-        stale-issue-message: 'This issue is marked stale. It will be closed in 30 days if it is not updated.'
-        stale-pr-message: 'This pull request is marked stale. It will be closed in 30 days if it is not updated.'
-        days-before-stale: 365
-        days-before-close: 30
-        stale-issue-label: "Stale"
-        stale-pr-label: "Stale"
-        operations-per-run: 20
-        remove-stale-when-updated: true
+      # First step: Handle regular issues (excluding needs-information)
+      - name: Mark regular issues as stale
+        uses: actions/stale@v9
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+
+          # Default stale policy
+          days-before-stale: ${{ env.DAYS_BEFORE_STALE }}
+          days-before-close: ${{ env.DAYS_BEFORE_CLOSE }}
+
+          # Explicit stale label configuration
+          stale-issue-label: "stale"
+          stale-pr-label: "stale"
+
+          stale-issue-message: |
+            This issue has been automatically marked as stale due to inactivity.
+            It will be closed in 30 days if no further activity occurs.
+            If you believe this issue is still relevant, please add a comment to keep it open.
+
+          close-issue-message: |
+            This issue has been automatically closed due to inactivity.
+            If you believe this issue is still relevant, please reopen it or create a new issue with updated information.
+
+          # Exclude needs-information issues from this step
+          exempt-issue-labels: 'no-stale,needs-information'
+
+          # Remove stale label when issue/PR becomes active again
+          remove-stale-when-updated: true
+
+          # Apply to pull requests with same timeline
+          days-before-pr-stale: ${{ env.DAYS_BEFORE_STALE }}
+          days-before-pr-close: ${{ env.DAYS_BEFORE_CLOSE }}
+
+          stale-pr-message: |
+            This pull request has been automatically marked as stale due to inactivity.
+            It will be closed in 30 days if no further activity occurs.
+
+          close-pr-message: |
+            This pull request has been automatically closed due to inactivity.
+            If you would like to continue this work, please reopen the PR or create a new one.
+
+          # Only exclude no-stale PRs (needs-information PRs follow standard timeline)
+          exempt-pr-labels: 'no-stale'
+
+      # Second step: Handle needs-information issues with accelerated timeline
+      - name: Mark needs-information issues as stale
+        uses: actions/stale@v9
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+
+          # Accelerated timeline for needs-information
+          days-before-stale: ${{ env.NEEDS_INFO_DAYS_BEFORE_STALE }}
+          days-before-close: ${{ env.NEEDS_INFO_DAYS_BEFORE_CLOSE }}
+
+          # Explicit stale label configuration
+          stale-issue-label: "stale"
+
+          # Only target ISSUES with needs-information label (not PRs)
+          only-issue-labels: 'needs-information'
+
+          stale-issue-message: |
+            This issue has been marked as stale because it requires additional information
+            that has not been provided for 30 days. It will be closed in 7 days if the
+            requested information is not provided.
+
+          close-issue-message: |
+            This issue has been closed because the requested information was not provided within the specified timeframe.
+            If you can provide the missing information, please reopen this issue or create a new one.
+
+          # Disable PR processing for this step
+          days-before-pr-stale: -1
+          days-before-pr-close: -1
+
+          # Remove stale label when issue becomes active again
+          remove-stale-when-updated: true

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": {},

doctests/dt_bitmap.py

@@ -6,11 +6,13 @@
 """
 import redis
 
-r = redis.Redis(decode_responses=True)
+# Connect without the usual `decode_responses=True` to
+# see the binary values in the responses more easily.
+r = redis.Redis()
 # HIDE_END
 
 # REMOVE_START
-r.delete("pings:2024-01-01-00:00")
+r.delete("pings:2024-01-01-00:00", "A", "B", "C", "R")
 # REMOVE_END
 
 # STEP_START ping
@@ -38,3 +40,116 @@
 # REMOVE_START
 assert res4 == 1
 # REMOVE_END
+
+# STEP_START bitop_setup
+r.setbit("A", 0, 1)
+r.setbit("A", 1, 1)
+r.setbit("A", 3, 1)
+r.setbit("A", 4, 1)
+
+res5 = r.get("A")
+print("{:08b}".format(int.from_bytes(res5, "big")))
+# >>> 11011000
+
+r.setbit("B", 3, 1)
+r.setbit("B", 4, 1)
+r.setbit("B", 7, 1)
+
+res6 = r.get("B")
+print("{:08b}".format(int.from_bytes(res6, "big")))
+# >>> 00011001
+
+r.setbit("C", 1, 1)
+r.setbit("C", 2, 1)
+r.setbit("C", 4, 1)
+r.setbit("C", 5, 1)
+
+res7 = r.get("C")
+print("{:08b}".format(int.from_bytes(res7, "big")))
+# >>> 01101100
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res5, "big") == 0b11011000
+assert int.from_bytes(res6, "big") == 0b00011001
+assert int.from_bytes(res7, "big") == 0b01101100
+# REMOVE_END
+
+# STEP_START bitop_and
+r.bitop("AND", "R", "A", "B", "C")
+res8 = r.get("R")
+print("{:08b}".format(int.from_bytes(res8, "big")))
+# >>> 00001000
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res8, "big") == 0b00001000
+# REMOVE_END
+
+# STEP_START bitop_or
+r.bitop("OR", "R", "A", "B", "C")
+res9 = r.get("R")
+print("{:08b}".format(int.from_bytes(res9, "big")))
+# >>> 11111101
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res9, "big") == 0b11111101
+# REMOVE_END
+
+# STEP_START bitop_xor
+r.bitop("XOR", "R", "A", "B")
+res10 = r.get("R")
+print("{:08b}".format(int.from_bytes(res10, "big")))
+# >>> 11000001
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res10, "big") == 0b11000001
+# REMOVE_END
+
+# STEP_START bitop_not
+r.bitop("NOT", "R", "A")
+res11 = r.get("R")
+print("{:08b}".format(int.from_bytes(res11, "big")))
+# >>> 00100111
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res11, "big") == 0b00100111
+# REMOVE_END
+
+# STEP_START bitop_diff
+r.bitop("DIFF", "R", "A", "B", "C")
+res12 = r.get("R")
+print("{:08b}".format(int.from_bytes(res12, "big")))
+# >>> 10000000
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res12, "big") == 0b10000000
+# REMOVE_END
+
+# STEP_START bitop_diff1
+r.bitop("DIFF1", "R", "A", "B", "C")
+res13 = r.get("R")
+print("{:08b}".format(int.from_bytes(res13, "big")))
+# >>> 00100101
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res13, "big") == 0b00100101
+# REMOVE_END
+
+# STEP_START bitop_andor
+r.bitop("ANDOR", "R", "A", "B", "C")
+res14 = r.get("R")
+print("{:08b}".format(int.from_bytes(res14, "big")))
+# >>> 01011000
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res14, "big") == 0b01011000
+# REMOVE_END
+
+# STEP_START bitop_one
+r.bitop("ONE", "R", "A", "B", "C")
+res15 = r.get("R")
+print("{:08b}".format(int.from_bytes(res15, "big")))
+# >>> 10100101
+# STEP_END
+# REMOVE_START
+assert int.from_bytes(res15, "big") == 0b10100101
+# REMOVE_END