Version 2.1.9

.bumpversion.cfg

@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 2.1.8
+current_version = 2.1.9
 commit = False
 tag = False
 message = 'Version {new_version}'

README.md

@@ -1,4 +1,4 @@
-# cb-util 2.1.8
+# cb-util 2.1.9
 
 ## Couchbase Utilities
 Couchbase connection manager. Simplifies connecting to a Couchbase cluster and performing data and management operations.

VERSION

@@ -1 +1 @@
-2.1.8
+2.1.9

cbcmgr/__init__.py

@@ -2,7 +2,7 @@
 from pkg_resources import parse_version
 
 _ROOT = os.path.abspath(os.path.dirname(__file__))
-__version__ = "2.1.8"
+__version__ = "2.1.9"
 VERSION = parse_version(__version__)
 
 

cbcmgr/async_pool.py

@@ -82,7 +82,7 @@ async def dispatch(self, keyspace: str, op: Operation, *args):
 
     async def join(self):
         if len(self.tasks) > 0:
-            await asyncio.sleep(0)
+            await asyncio.sleep(1)
             results = await asyncio.gather(*self.tasks, return_exceptions=True)
             for result in results:
                 if isinstance(result, Exception):

requirements.txt

@@ -1,5 +1,5 @@
 attrs==23.1.0
-couchbase>=4.1.8
+couchbase>=4.1.9
 dnspython==2.3.0
 docker==6.1.3
 pytest==7.4.0

setup.py

@@ -22,7 +22,7 @@
     package_data={'cbcmgr': ['data/*']},
     install_requires=[
         "attrs>=22.2.0",
-        "couchbase>=4.1.8",
+        "couchbase>=4.1.9",
         "dnspython>=2.3.0",
         "docker>=5.0.3",
         "pytest>=7.0.1",

tests/test_1.py

@@ -162,11 +162,13 @@ def setup_class(cls):
             time.sleep(1)
         command = ['cbcutil', 'list', '--host', '127.0.0.1', '--wait']
         run_in_container(cls.container_id, command)
+        time.sleep(1)
 
     @classmethod
     def teardown_class(cls):
         print("Stopping test container")
         stop_container(cls.container_id)
+        time.sleep(1)
 
     @pytest.mark.parametrize("hostname", ["127.0.0.1"])
     @pytest.mark.parametrize("bucket", ["test"])
@@ -217,11 +219,13 @@ def setup_class(cls):
             time.sleep(1)
         command = ['cbcutil', 'list', '--host', '127.0.0.1', '--wait']
         run_in_container(cls.container_id, command)
+        time.sleep(1)
 
     @classmethod
     def teardown_class(cls):
         print("Stopping test container")
         stop_container(cls.container_id)
+        time.sleep(1)
 
     @pytest.mark.parametrize("hostname", ["127.0.0.1"])
     @pytest.mark.parametrize("bucket", ["test"])

tests/test_2.py

@@ -138,11 +138,13 @@ def setup_class(cls):
             time.sleep(1)
         command = ['cbcutil', 'list', '--host', '127.0.0.1', '--wait']
         run_in_container(cls.container_id, command)
+        time.sleep(1)
 
     @classmethod
     def teardown_class(cls):
         print("Stopping test container")
         stop_container(cls.container_id)
+        time.sleep(1)
 
     @pytest.mark.parametrize("hostname", ["127.0.0.1"])
     @pytest.mark.parametrize("bucket", ["test"])
@@ -151,7 +153,7 @@ def teardown_class(cls):
     @pytest.mark.parametrize("tls", [False, True])
     @pytest.mark.asyncio
     async def test_1(self, hostname, bucket, tls, scope, collection):
-        pool = CBPoolAsync(hostname, "Administrator", "password", ssl=False, quota=128, create=True, replicas=0)
+        pool = CBPoolAsync(hostname, "Administrator", "password", ssl=tls, quota=128, create=True, replicas=0)
 
         for n in range(10):
             c = string.ascii_lowercase[n:n + 1]