chore: bump components version

Author: Nicolas Steinmetz

arq/connections.py

@@ -312,8 +312,5 @@ async def log_redis_info(redis: 'Redis[bytes]', log_func: Callable[[str], Any])
     clients_connected = info_clients.get('connected_clients', '?')
 
     log_func(
-        f'redis_version={redis_version} '
-        f'mem_usage={mem_usage} '
-        f'clients_connected={clients_connected} '
-        f'db_keys={key_count}'
+        f'redis_version={redis_version} mem_usage={mem_usage} clients_connected={clients_connected} db_keys={key_count}'
     )

arq/worker.py

@@ -82,7 +82,7 @@ def func(
 
     if isinstance(coroutine, str):
         name = name or coroutine
-        coroutine_: 'WorkerCoroutine' = import_string(coroutine)
+        coroutine_: WorkerCoroutine = import_string(coroutine)
     else:
         coroutine_ = coroutine
 
@@ -870,7 +870,7 @@ async def close(self) -> None:
         await self.pool.delete(self.health_check_key)
         if self.on_shutdown:
             await self.on_shutdown(self.ctx)
-        await self.pool.close(close_connection_pool=True)
+        await self.pool.aclose(close_connection_pool=True)
         self._pool = None
 
     def __repr__(self) -> str:
@@ -911,7 +911,7 @@ async def async_check_health(
     else:
         logger.info('Health check successful: %s', data)
         r = 0
-    await redis.close(close_connection_pool=True)
+    await redis.aclose(close_connection_pool=True)
     return r
 
 

pyproject.toml

@@ -38,10 +38,10 @@ classifiers = [
 ]
 requires-python = '>=3.9'
 dependencies = [
-    'redis[hiredis]>=4.2.0,<7',
-    'click>=8.0',
+    'redis[hiredis]>=5,<7',
+    'click>=8,<8.2',
 ]
-optional-dependencies = {watch = ['watchfiles>=0.16'] }
+optional-dependencies = {watch = ['watchfiles>=1.0'] }
 dynamic = ['version']
 
 [project.scripts]

requirements/docs.txt

@@ -31,7 +31,7 @@ requests==2.32.3
 snowballstemmer==2.2.0
     # via sphinx
 sphinx==5.3.0
-    # via -r docs.in
+    # via -r requirements/docs.in
 sphinxcontrib-applehelp==1.0.8
     # via sphinx
 sphinxcontrib-devhelp==1.0.6

requirements/linting.txt

@@ -10,19 +10,19 @@ cryptography==42.0.5
     # via
     #   types-pyopenssl
     #   types-redis
-mypy==1.9.0
+mypy==1.15.0
     # via -r requirements/linting.in
 mypy-extensions==1.0.0
     # via mypy
 pycparser==2.22
     # via cffi
-ruff==0.3.4
+ruff==0.11.9
     # via -r requirements/linting.in
 types-pyopenssl==24.0.0.20240311
     # via types-redis
 types-pytz==2024.1.0.20240203
     # via -r requirements/linting.in
 types-redis==4.6.0.20240311
     # via -r requirements/linting.in
-typing-extensions==4.10.0
+typing-extensions==4.12.2
     # via mypy

requirements/pyproject.txt

@@ -8,13 +8,13 @@ anyio==4.3.0
     # via watchfiles
 click==8.1.7
     # via arq (pyproject.toml)
-hiredis==2.3.2
+hiredis==3.1.1
     # via redis
 idna==3.7
     # via anyio
-redis==4.6.0
+redis==5.0.8
     # via arq (pyproject.toml)
 sniffio==1.3.1
     # via anyio
-watchfiles==0.21.0
+watchfiles==1.0.5
     # via arq (pyproject.toml)

requirements/testing.in

@@ -8,4 +8,4 @@ pytest-mock
 pytest-pretty
 pytest-timeout
 pytz
-testcontainers<4  # until we remove 3.8 support
+testcontainers

requirements/testing.txt

@@ -1,5 +1,5 @@
 #
-# This file is autogenerated by pip-compile with Python 3.9
+# This file is autogenerated by pip-compile with Python 3.12
 # by the following command:
 #
 #    pip-compile --output-file=requirements/testing.txt --strip-extras requirements/testing.in
@@ -18,8 +18,6 @@ dirty-equals==0.7.1.post0
     # via -r requirements/testing.in
 docker==7.1.0
     # via testcontainers
-exceptiongroup==1.2.2
-    # via pytest
 idna==3.7
     # via requests
 iniconfig==2.0.0
@@ -36,9 +34,9 @@ packaging==24.0
     #   pytest
 pluggy==1.4.0
     # via pytest
-pydantic==2.6.4
+pydantic==2.11.4
     # via -r requirements/testing.in
-pydantic-core==2.16.3
+pydantic-core==2.33.2
     # via pydantic
 pygments==2.17.2
     # via rich
@@ -65,13 +63,9 @@ requests==2.32.3
     # via docker
 rich==13.7.1
     # via pytest-pretty
-testcontainers==3.7.1
+testcontainers==4.10.0
     # via -r requirements/testing.in
-tomli==2.0.1
-    # via
-    #   coverage
-    #   pytest
-typing-extensions==4.10.0
+typing-extensions==4.12.2
     # via
     #   pydantic
     #   pydantic-core

tests/conftest.py

@@ -38,7 +38,7 @@ def test_redis_host(redis_container: RedisContainer) -> str:
 
 @pytest.fixture(scope='session')
 def test_redis_port(redis_container: RedisContainer) -> int:
-    return redis_container.get_exposed_port(redis_container.port_to_expose)
+    return redis_container.get_exposed_port(6379)
 
 
 @pytest.fixture(scope='session')
@@ -58,7 +58,7 @@ async def arq_redis(test_redis_host: str, test_redis_port: int):
 
     yield redis_
 
-    await redis_.close(close_connection_pool=True)
+    await redis_.aclose(close_connection_pool=True)
 
 
 @pytest.fixture
@@ -72,7 +72,7 @@ async def arq_redis_msgpack(test_redis_host: str, test_redis_port: int):
     )
     await redis_.flushall()
     yield redis_
-    await redis_.close(close_connection_pool=True)
+    await redis_.aclose(close_connection_pool=True)
 
 
 @pytest.fixture
@@ -87,7 +87,7 @@ async def arq_redis_retry(test_redis_host: str, test_redis_port: int):
     )
     await redis_.flushall()
     yield redis_
-    await redis_.close(close_connection_pool=True)
+    await redis_.aclose(close_connection_pool=True)
 
 
 @pytest.fixture
@@ -140,7 +140,7 @@ async def create_pool_(settings, *args, **kwargs):
 
     yield create_pool_
 
-    await asyncio.gather(*[p.close(close_connection_pool=True) for p in pools])
+    await asyncio.gather(*[p.aclose(close_connection_pool=True) for p in pools])
 
 
 @pytest.fixture(name='cancel_remaining_task')

tests/test_utils.py

@@ -59,11 +59,11 @@ async def test_redis_success_log(test_redis_settings: RedisSettings, caplog, cre
     caplog.set_level(logging.INFO)
     pool = await create_pool(test_redis_settings)
     assert 'redis connection successful' not in [r.message for r in caplog.records]
-    await pool.close(close_connection_pool=True)
+    await pool.aclose(close_connection_pool=True)
 
     pool = await create_pool(test_redis_settings, retry=1)
     assert 'redis connection successful' in [r.message for r in caplog.records]
-    await pool.close(close_connection_pool=True)
+    await pool.aclose(close_connection_pool=True)
 
 
 async def test_redis_log(test_redis_settings: RedisSettings, create_pool):