Bump pyupgrade version and add __future__.annotations import

16 files changed, 33 insertions, 0 deletions

diff --git a/examples/complete_receive.py b/examples/complete_receive.py
index 21903c59..1f1fb5e2 100644
--- a/examples/complete_receive.py
+++ b/examples/complete_receive.py
@@ -4,6 +4,8 @@ and exits.
 
 """
 
+from __future__ import annotations
+
 from pprint import pformat
 
 from kombu import Connection, Consumer, Exchange, Queue, eventloop
diff --git a/examples/complete_send.py b/examples/complete_send.py
index d4643e59..ea7ab65c 100644
--- a/examples/complete_send.py
+++ b/examples/complete_send.py
@@ -6,6 +6,8 @@ You can use `complete_receive.py` to receive the message sent.
 
 """
 
+from __future__ import annotations
+
 from kombu import Connection, Exchange, Producer, Queue
 
 #: By default messages sent to exchanges are persistent (delivery_mode=2),
diff --git a/examples/experimental/async_consume.py b/examples/experimental/async_consume.py
index 5f70b4ed..55126bda 100644
--- a/examples/experimental/async_consume.py
+++ b/examples/experimental/async_consume.py
@@ -1,5 +1,7 @@
 #!/usr/bin/env python
 
+from __future__ import annotations
+
 from kombu import Connection, Consumer, Exchange, Producer, Queue
 from kombu.asynchronous import Hub
 
diff --git a/examples/hello_consumer.py b/examples/hello_consumer.py
index 3a0d9f06..38b2b61d 100644
--- a/examples/hello_consumer.py
+++ b/examples/hello_consumer.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 from kombu import Connection
 
 with Connection('amqp://guest:guest@localhost:5672//') as conn:
diff --git a/examples/hello_publisher.py b/examples/hello_publisher.py
index 48342800..dfb2df8e 100644
--- a/examples/hello_publisher.py
+++ b/examples/hello_publisher.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 import datetime
 
 from kombu import Connection
diff --git a/examples/memory_transport.py b/examples/memory_transport.py
index 8d667b81..e25cc898 100644
--- a/examples/memory_transport.py
+++ b/examples/memory_transport.py
@@ -1,6 +1,8 @@
 """
 Example that use memory transport for message produce.
 """
+from __future__ import annotations
+
 import time
 
 from kombu import Connection, Consumer, Exchange, Queue
diff --git a/examples/rpc-tut6/rpc_client.py b/examples/rpc-tut6/rpc_client.py
index 6b1d509b..a899bd5c 100644
--- a/examples/rpc-tut6/rpc_client.py
+++ b/examples/rpc-tut6/rpc_client.py
@@ -1,5 +1,7 @@
 #!/usr/bin/env python
 
+from __future__ import annotations
+
 from kombu import Connection, Consumer, Producer, Queue, uuid
 
 
diff --git a/examples/rpc-tut6/rpc_server.py b/examples/rpc-tut6/rpc_server.py
index 761630ca..ce13ea83 100644
--- a/examples/rpc-tut6/rpc_server.py
+++ b/examples/rpc-tut6/rpc_server.py
@@ -1,5 +1,7 @@
 #!/usr/bin/env python
 
+from __future__ import annotations
+
 from kombu import Connection, Queue
 from kombu.mixins import ConsumerProducerMixin
 
diff --git a/examples/simple_eventlet_receive.py b/examples/simple_eventlet_receive.py
index 33f09d80..703203ad 100644
--- a/examples/simple_eventlet_receive.py
+++ b/examples/simple_eventlet_receive.py
@@ -7,6 +7,8 @@ message sent.
 
 """
 
+from __future__ import annotations
+
 import eventlet
 
 from kombu import Connection
diff --git a/examples/simple_eventlet_send.py b/examples/simple_eventlet_send.py
index 9a753e7a..ad0c1f2b 100644
--- a/examples/simple_eventlet_send.py
+++ b/examples/simple_eventlet_send.py
@@ -7,6 +7,8 @@ message sent.
 
 """
 
+from __future__ import annotations
+
 import eventlet
 
 from kombu import Connection
diff --git a/examples/simple_receive.py b/examples/simple_receive.py
index 90c2d0ae..c2512cca 100644
--- a/examples/simple_receive.py
+++ b/examples/simple_receive.py
@@ -3,6 +3,8 @@ Example receiving a message using the SimpleQueue interface.
 
 """
 
+from __future__ import annotations
+
 from kombu import Connection
 
 #: Create connection
diff --git a/examples/simple_send.py b/examples/simple_send.py
index d2eacea4..194fb810 100644
--- a/examples/simple_send.py
+++ b/examples/simple_send.py
@@ -7,6 +7,8 @@ message sent.
 
 """
 
+from __future__ import annotations
+
 from kombu import Connection
 
 #: Create connection
diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py
index bc2d180f..aaa18f5c 100644
--- a/examples/simple_task_queue/client.py
+++ b/examples/simple_task_queue/client.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 from kombu.pools import producers
 
 from .queues import task_exchange
diff --git a/examples/simple_task_queue/queues.py b/examples/simple_task_queue/queues.py
index 602c2b0e..a545b4c2 100644
--- a/examples/simple_task_queue/queues.py
+++ b/examples/simple_task_queue/queues.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 from kombu import Exchange, Queue
 
 task_exchange = Exchange('tasks', type='direct')
diff --git a/examples/simple_task_queue/tasks.py b/examples/simple_task_queue/tasks.py
index 2810f7a8..02edda07 100644
--- a/examples/simple_task_queue/tasks.py
+++ b/examples/simple_task_queue/tasks.py
@@ -1,2 +1,5 @@
+from __future__ import annotations
+
+
 def hello_task(who='world'):
     print(f'Hello {who}')
diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py
index 66ad9c30..4d16e309 100644
--- a/examples/simple_task_queue/worker.py
+++ b/examples/simple_task_queue/worker.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 from kombu.log import get_logger
 from kombu.mixins import ConsumerMixin
 from kombu.utils.functional import reprcall