Dependencies: Add support for Python 3.12

.github/workflows/cd.yml

@@ -58,7 +58,7 @@ jobs:
 
         strategy:
             matrix:
-                python-version: ['3.8', '3.9', '3.10', '3.11']
+                python-version: ['3.8', '3.9', '3.10', '3.11', '3.12']
 
         services:
             rabbitmq:

.github/workflows/ci.yml

@@ -26,7 +26,7 @@ jobs:
         strategy:
             fail-fast: false
             matrix:
-                python-version: ['3.8', '3.9', '3.10', '3.11']
+                python-version: ['3.8', '3.9', '3.10', '3.11', '3.12']
                 rabbitmq: [latest]
                 include:
                 -   python-version: '3.8'

docs/source/conf.py

@@ -55,7 +55,7 @@
 
 intersphinx_mapping = {
     'python': ('https://docs.python.org/3.8', None),
-    'aio_pika': ('https://aio-pika.readthedocs.io/en/latest/', None)
+    'aio_pika': ('https://docs.aio-pika.com/', None)
 }
 
 # Add any paths that contain templates here, relative to this directory.

docs/source/performance.rst

@@ -1,5 +1,5 @@
 .. _pika: https://pika.readthedocs.io/en/stable/
-.. _aio-pika: https://pika.readthedocs.io/en/stable/
+.. _aio-pika: https://docs.aio-pika.com/
 .. _msgpack: https://github.com/msgpack/msgpack-python
 
 

docs/source/pika-comparison.rst

@@ -4,7 +4,7 @@
 .. _work queues: https://www.rabbitmq.com/tutorials/tutorial-two-python.html
 .. _topics: https://www.rabbitmq.com/tutorials/tutorial-five-python.html
 .. _RPC: https://www.rabbitmq.com/tutorials/tutorial-six-python.html
-.. _aio-pika: https://aio-pika.readthedocs.io/en/latest/index.html
+.. _aio-pika: https://docs.aio-pika.com/index.html
 
 Coming from Pika
 ================

pyproject.toml

@@ -22,6 +22,7 @@ classifiers = [
     'Programming Language :: Python :: 3.9',
     'Programming Language :: Python :: 3.10',
     'Programming Language :: Python :: 3.11',
+    'Programming Language :: Python :: 3.12',
 ]
 keywords = ['ommunication', 'messaging', 'rpc', 'broadcast']
 requires-python = '>=3.8'
@@ -50,7 +51,7 @@ pre-commit = [
     'pylint==2.12.2',
 ]
 rmq = [
-    'aio-pika~=9.0',
+    'aio-pika~=9.4.0',
     'pamqp~=3.2',
     'pytray>=0.3.4,<0.4.0',
 ]
@@ -60,7 +61,7 @@ tests = [
     'pytest-cov',
     'pytest~=7.0',
     'pytest-asyncio~=0.12,<0.17',
-    'pytest-notebook>=0.7',
+    'pytest-notebook>=0.9',
     'pytest-benchmark',
     'pika',
     'msgpack',

src/kiwipy/rmq/tasks.py

@@ -119,6 +119,9 @@ async def next_task(self,
         raises:
             kiwipy.exceptions.QueueEmpty: When the queue has no tasks within the timeout
         """
+        # relinquish so that if there is requeue coroutines, they are run first and task queue get updated
+        await asyncio.sleep(0)
+
         try:
             message = await self._task_queue.get(no_ack=no_ack, fail=fail, timeout=timeout)
         except aio_pika.exceptions.QueueEmpty as exc: