summaryrefslogtreecommitdiff
path: root/examples/simple_task_queue
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2016-04-06 13:14:05 -0700
committerAsk Solem <ask@celeryproject.org>2016-04-06 13:14:05 -0700
commitb3741774735daa205edd3fbe29e74f8bbec296ee (patch)
tree2c0bb51c209c94a6c34afc7ce0381ae580c74563 /examples/simple_task_queue
parent646ef049b46a9f61748d663edb40a47fe1fc08d4 (diff)
downloadkombu-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.py10
-rw-r--r--examples/simple_task_queue/queues.py2
-rw-r--r--examples/simple_task_queue/tasks.py2
-rw-r--r--examples/simple_task_queue/worker.py2
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