diff options
Diffstat (limited to 'examples/simple_task_queue')
| -rw-r--r-- | examples/simple_task_queue/client.py | 2 | ||||
| -rw-r--r-- | examples/simple_task_queue/queues.py | 2 | ||||
| -rw-r--r-- | examples/simple_task_queue/tasks.py | 3 | ||||
| -rw-r--r-- | examples/simple_task_queue/worker.py | 2 |
4 files changed, 9 insertions, 0 deletions
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 |