From 7516daf7a774dd9671d16c475c6ac266de977a0a Mon Sep 17 00:00:00 2001 From: Marcelo Trylesinski Date: Thu, 14 Apr 2022 13:02:52 +0200 Subject: Bump pyupgrade version and add __future__.annotations import --- examples/complete_receive.py | 2 ++ examples/complete_send.py | 2 ++ examples/experimental/async_consume.py | 2 ++ examples/hello_consumer.py | 2 ++ examples/hello_publisher.py | 2 ++ examples/memory_transport.py | 2 ++ examples/rpc-tut6/rpc_client.py | 2 ++ examples/rpc-tut6/rpc_server.py | 2 ++ examples/simple_eventlet_receive.py | 2 ++ examples/simple_eventlet_send.py | 2 ++ examples/simple_receive.py | 2 ++ examples/simple_send.py | 2 ++ examples/simple_task_queue/client.py | 2 ++ examples/simple_task_queue/queues.py | 2 ++ examples/simple_task_queue/tasks.py | 3 +++ examples/simple_task_queue/worker.py | 2 ++ 16 files changed, 33 insertions(+) (limited to 'examples') 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 -- cgit v1.2.1