Script 'mail_helper' called by obssrc Hello community, here is the log from the commit of package python-redis for openSUSE:Factory checked in at 2024-01-17 22:14:40 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Comparing /work/SRC/openSUSE:Factory/python-redis (Old) and /work/SRC/openSUSE:Factory/.python-redis.new.16006 (New) ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Package is "python-redis" Wed Jan 17 22:14:40 2024 rev:38 rq:1139023 version:5.0.1 Changes: -------- --- /work/SRC/openSUSE:Factory/python-redis/python-redis.changes 2024-01-05 22:58:46.640491210 +0100 +++ /work/SRC/openSUSE:Factory/.python-redis.new.16006/python-redis.changes 2024-01-17 22:14:44.097751891 +0100 @@ -1,0 +2,7 @@ +Mon Jan 15 20:19:45 UTC 2024 - Dirk Müller <[email protected]> + +- add https://github.com/redis/redis-py/pull/3005 as + Close-various-objects-created-during-asyncio-tests.patch + to fix tests for python 3.12 + +------------------------------------------------------------------- New: ---- Close-various-objects-created-during-asyncio-tests.patch BETA DEBUG BEGIN: New:- add https://github.com/redis/redis-py/pull/3005 as Close-various-objects-created-during-asyncio-tests.patch to fix tests for python 3.12 BETA DEBUG END: ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Other differences: ------------------ ++++++ python-redis.spec ++++++ --- /var/tmp/diff_new_pack.9AJ4Uw/_old 2024-01-17 22:14:44.617770988 +0100 +++ /var/tmp/diff_new_pack.9AJ4Uw/_new 2024-01-17 22:14:44.617770988 +0100 @@ -28,6 +28,8 @@ Source0: https://files.pythonhosted.org/packages/source/r/redis/redis-%{version}.tar.gz Source1: https://raw.githubusercontent.com/redis/redis-py/5.0/pytest.ini Patch0: increase-test-timeout.patch +# PATCH-FIX-UPSTREAM https://github.com/redis/redis-py/pull/3005 +Patch1: Close-various-objects-created-during-asyncio-tests.patch BuildRequires: %{python_module async-timeout >= 4.0.2} BuildRequires: %{python_module base >= 3.7} BuildRequires: %{python_module packaging} @@ -57,6 +59,7 @@ %ifarch s390x %patch -P 0 -p1 %endif +%patch -P 1 -p1 # This test passes locally but fails in obs with different # environment, like ALP build... ++++++ Close-various-objects-created-during-asyncio-tests.patch ++++++ >From 29d867899ab7abfb0ec2ef73d5bd3a810f8ab432 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kristj=C3=A1n=20Valur=20J=C3=B3nsson?= <[email protected]> Date: Fri, 13 Oct 2023 15:54:23 +0000 Subject: [PATCH] Close various objects created during asyncio tests --- tests/test_asyncio/test_commands.py | 2 ++ tests/test_asyncio/test_connect.py | 2 ++ tests/test_asyncio/test_connection.py | 4 ++++ tests/test_asyncio/test_retry.py | 3 +++ tests/test_asyncio/test_sentinel.py | 22 +++++++++---------- .../test_sentinel_managed_connection.py | 1 + 6 files changed, 23 insertions(+), 11 deletions(-) diff --git a/tests/test_asyncio/test_commands.py b/tests/test_asyncio/test_commands.py index 9b9852e9ef..35b9f2a29f 100644 --- a/tests/test_asyncio/test_commands.py +++ b/tests/test_asyncio/test_commands.py @@ -370,10 +370,12 @@ async def test_client_setinfo(self, r: redis.Redis): info = await r2.client_info() assert info["lib-name"] == "test2" assert info["lib-ver"] == "1234" + await r2.aclose() r3 = redis.asyncio.Redis(lib_name=None, lib_version=None) info = await r3.client_info() assert info["lib-name"] == "" assert info["lib-ver"] == "" + await r3.aclose() @skip_if_server_version_lt("2.6.9") @pytest.mark.onlynoncluster diff --git a/tests/test_asyncio/test_connect.py b/tests/test_asyncio/test_connect.py index 0b2d7c2afa..5e6b120fb3 100644 --- a/tests/test_asyncio/test_connect.py +++ b/tests/test_asyncio/test_connect.py @@ -73,6 +73,8 @@ async def _handler(reader, writer): try: return await _redis_request_handler(reader, writer, stop_event) finally: + writer.close() + await writer.wait_closed() finished.set() if isinstance(server_address, str): diff --git a/tests/test_asyncio/test_connection.py b/tests/test_asyncio/test_connection.py index 28e6b0d9c3..9c7f25bf87 100644 --- a/tests/test_asyncio/test_connection.py +++ b/tests/test_asyncio/test_connection.py @@ -85,6 +85,8 @@ async def get_conn(_): assert init_call_count == 1 assert command_call_count == 2 + r.connection = None # it was a Mock + await r.aclose() @skip_if_server_version_lt("4.0.0") @@ -143,6 +145,7 @@ async def mock_connect(): conn._connect.side_effect = mock_connect await conn.connect() assert conn._connect.call_count == 3 + await conn.disconnect() async def test_connect_without_retry_on_os_error(): @@ -194,6 +197,7 @@ async def test_connection_parse_response_resume(r: redis.Redis): pytest.fail("didn't receive a response") assert response assert i > 0 + await conn.disconnect() @pytest.mark.onlynoncluster diff --git a/tests/test_asyncio/test_retry.py b/tests/test_asyncio/test_retry.py index 2912ca786c..8bc71c1479 100644 --- a/tests/test_asyncio/test_retry.py +++ b/tests/test_asyncio/test_retry.py @@ -131,5 +131,8 @@ async def test_get_set_retry_object(self, request): assert r.get_retry()._retries == new_retry_policy._retries assert isinstance(r.get_retry()._backoff, ExponentialBackoff) assert exiting_conn.retry._retries == new_retry_policy._retries + await r.connection_pool.release(exiting_conn) new_conn = await r.connection_pool.get_connection("_") assert new_conn.retry._retries == new_retry_policy._retries + await r.connection_pool.release(new_conn) + await r.aclose() diff --git a/tests/test_asyncio/test_sentinel.py b/tests/test_asyncio/test_sentinel.py index 25bd7730da..51e59d69d0 100644 --- a/tests/test_asyncio/test_sentinel.py +++ b/tests/test_asyncio/test_sentinel.py @@ -183,13 +183,13 @@ async def test_discover_slaves(cluster, sentinel): @pytest.mark.onlynoncluster async def test_master_for(cluster, sentinel, master_ip): - master = sentinel.master_for("mymaster", db=9) - assert await master.ping() - assert master.connection_pool.master_address == (master_ip, 6379) + async with sentinel.master_for("mymaster", db=9) as master: + assert await master.ping() + assert master.connection_pool.master_address == (master_ip, 6379) # Use internal connection check - master = sentinel.master_for("mymaster", db=9, check_connection=True) - assert await master.ping() + async with sentinel.master_for("mymaster", db=9, check_connection=True) as master: + assert await master.ping() @pytest.mark.onlynoncluster @@ -197,16 +197,16 @@ async def test_slave_for(cluster, sentinel): cluster.slaves = [ {"ip": "127.0.0.1", "port": 6379, "is_odown": False, "is_sdown": False} ] - slave = sentinel.slave_for("mymaster", db=9) - assert await slave.ping() + async with sentinel.slave_for("mymaster", db=9) as slave: + assert await slave.ping() @pytest.mark.onlynoncluster async def test_slave_for_slave_not_found_error(cluster, sentinel): cluster.master["is_odown"] = True - slave = sentinel.slave_for("mymaster", db=9) - with pytest.raises(SlaveNotFoundError): - await slave.ping() + async with sentinel.slave_for("mymaster", db=9) as slave: + with pytest.raises(SlaveNotFoundError): + await slave.ping() @pytest.mark.onlynoncluster @@ -260,7 +260,7 @@ async def mock_disconnect(): calls += 1 with mock.patch.object(pool, "disconnect", mock_disconnect): - await client.close() + await client.aclose() assert calls == 1 await pool.disconnect() diff --git a/tests/test_asyncio/test_sentinel_managed_connection.py b/tests/test_asyncio/test_sentinel_managed_connection.py index 711b3ee733..cae4b9581f 100644 --- a/tests/test_asyncio/test_sentinel_managed_connection.py +++ b/tests/test_asyncio/test_sentinel_managed_connection.py @@ -34,3 +34,4 @@ async def mock_connect(): conn._connect.side_effect = mock_connect await conn.connect() assert conn._connect.call_count == 3 + await conn.disconnect()
