Release/v2.10.0 (#680)

* Update GH workflow
* Bump version to v2.10.0

---------

Signed-off-by: Waldemar Quevedo <[email protected]>

Author: wallyqs

.github/workflows/test.yml

@@ -4,17 +4,23 @@ on:
   push:
     branches:
       - main
+      - "release/**"
+      - "dev/**"
   pull_request:
     branches:
       - "**"
 
 jobs:
   test:
-    runs-on: ${{ matrix.os }}
+    runs-on: ubuntu-latest
+    timeout-minutes: 20
+    env:
+      NATS_SERVER_VERSION: ${{ matrix.nats_version }}
     strategy:
+      fail-fast: false
       matrix:
-        os: [ubuntu-latest]
         python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        nats_version: ["v2.10.26", "v2.11.0", "main"]
 
     steps:
       - name: Check out repository
@@ -28,6 +34,7 @@ jobs:
       - name: Install dependencies
         run: |
           pip install pipenv
+          pip install certifi
           pipenv install --dev
           bash ./scripts/install_nats.sh
 

nats/aio/client.py

@@ -59,7 +59,7 @@
 )
 from .transport import TcpTransport, Transport, WebSocketTransport
 
-__version__ = "2.9.0"
+__version__ = "2.10.0"
 __lang__ = "python3"
 _logger = logging.getLogger(__name__)
 PROTOCOL = 1

tests/test_client.py

@@ -11,7 +11,7 @@
 import nats
 import nats.errors
 import pytest
-from nats.aio.client import Client as NATS, __version__, ServerVersion
+from nats.aio.client import Client as NATS, ServerVersion, __version__
 from tests.utils import (
     ClusteringDiscoveryAuthTestCase,
     ClusteringTestCase,

tests/test_js.py

@@ -2618,8 +2618,9 @@ async def error_handler(e):
         # Check remaining messages in the stream state.
         status = await kv.status()
         # NOTE: Behavior changed here from v2.10.9 => v2.10.10
-        # assert status.values == 2
-        assert status.values == 1
+        # then changed again around v2.10.26.
+        assert status.values == 2
+        # assert status.values == 1
 
         entry = await kv.get("hello")
         assert "hello" == entry.key
@@ -2634,13 +2635,13 @@ async def error_handler(e):
         assert 1 == entry.revision
 
         status = await kv.status()
-        assert status.values == 1
+        assert status.values == 2
 
         for i in range(100, 200):
             await kv.put(f"hello.{i}", b"Hello JS KV!")
 
         status = await kv.status()
-        assert status.values == 101
+        assert status.values == 102
 
         with pytest.raises(NotFoundError):
             await kv.get("hello.5")