diff options
author | Ask Solem <ask@celeryproject.org> | 2016-04-06 13:14:05 -0700 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2016-04-06 13:14:05 -0700 |
commit | b3741774735daa205edd3fbe29e74f8bbec296ee (patch) | |
tree | 2c0bb51c209c94a6c34afc7ce0381ae580c74563 /examples/simple_task_queue | |
parent | 646ef049b46a9f61748d663edb40a47fe1fc08d4 (diff) | |
download | kombu-b3741774735daa205edd3fbe29e74f8bbec296ee.tar.gz |
Use unicode_litereals everywhere and updates flakeplus target to --2.7
Diffstat (limited to 'examples/simple_task_queue')
-rw-r--r-- | examples/simple_task_queue/client.py | 10 | ||||
-rw-r--r-- | examples/simple_task_queue/queues.py | 2 | ||||
-rw-r--r-- | examples/simple_task_queue/tasks.py | 2 | ||||
-rw-r--r-- | examples/simple_task_queue/worker.py | 2 |
4 files changed, 13 insertions, 3 deletions
diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py index 1b249578..ec348cf5 100644 --- a/examples/simple_task_queue/client.py +++ b/examples/simple_task_queue/client.py @@ -1,10 +1,14 @@ +from __future__ import absolute_import, unicode_literals + from kombu.pools import producers from .queues import task_exchange -priority_to_routing_key = {'high': 'hipri', - 'mid': 'midpri', - 'low': 'lopri'} +priority_to_routing_key = { + 'high': 'hipri', + 'mid': 'midpri', + 'low': 'lopri', +} def send_as_task(connection, fun, args=(), kwargs={}, priority='mid'): diff --git a/examples/simple_task_queue/queues.py b/examples/simple_task_queue/queues.py index 602c2b0e..ccdc3f2c 100644 --- a/examples/simple_task_queue/queues.py +++ b/examples/simple_task_queue/queues.py @@ -1,3 +1,5 @@ +from __future__ import absolute_import, unicode_literals + 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 d3751506..1d520fad 100644 --- a/examples/simple_task_queue/tasks.py +++ b/examples/simple_task_queue/tasks.py @@ -1,2 +1,4 @@ +from __future__ import absolute_import, unicode_literals + def hello_task(who='world'): print('Hello {0}'.format(who)) diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py index 6113d4ac..6b617cf0 100644 --- a/examples/simple_task_queue/worker.py +++ b/examples/simple_task_queue/worker.py @@ -1,3 +1,5 @@ +from __future__ import absolute_import, unicode_literals + from kombu.mixins import ConsumerMixin from kombu.log import get_logger from kombu.utils import reprcall |