Merge pull request #537 from splitio/async-release

Async release 10.0.0

Author: chillaq

CHANGES.txt

@@ -1,4 +1,4 @@
-10.0.0 (XXX XX, XXXX)
+10.0.0 (Jun 27, 2024)
 - Added support for asyncio library
 - BREAKING CHANGE: Minimum supported Python version is 3.7.16
 

setup.cfg

@@ -2,7 +2,10 @@
 universal = 1
 
 [metadata]
-description-file = README.md
+name = splitio_client
+description = This SDK is designed to work with Split, the platform for controlled rollouts, which serves features to your users via a Split feature flag to manage your complete customer experience.
+long_description = file: README.md
+long_description_content_type = text/markdown
 
 [flake8]
 max-line-length=100

splitio/storage/adapters/redis.py

@@ -765,6 +765,7 @@ async def _build_default_client_async(config):  # pylint: disable=too-many-local
     host = config.get('redisHost', 'localhost')
     port = config.get('redisPort', 6379)
     database = config.get('redisDb', 0)
+    username = config.get('redisUsername', None)
     password = config.get('redisPassword', None)
     socket_timeout = config.get('redisSocketTimeout', None)
     socket_connect_timeout = config.get('redisSocketConnectTimeout', None)
@@ -789,6 +790,7 @@ async def _build_default_client_async(config):  # pylint: disable=too-many-local
             "redis://" + host + ":" + str(port),
             db=database,
             password=password,
+            username=username,
             max_connections=max_connections,
             encoding=encoding,
             decode_responses=decode_responses,

tests/integration/test_streaming_e2e.py

@@ -1952,7 +1952,6 @@ async def test_streaming_status_changes(self):
 
         assert await factory.client().get_treatment('maldo', 'split1') == 'on'
         assert task.running()
-        assert 'PushStatusHandler' not in [t.name for t in threading.enumerate()]
 
         # Validate the SSE request
         sse_request = sse_requests.get()
@@ -2385,7 +2384,6 @@ async def test_ably_errors_handling(self):
 
         # Assert sync-task is running and the streaming status handler thread is over
         assert task.running()
-        assert 'PushStatusHandler' not in [t.name for t in threading.enumerate()]
 
         # Validate the SSE requests
         sse_request = sse_requests.get()