summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2014-05-19 22:27:36 +0100
committerAsk Solem <ask@celeryproject.org>2014-05-19 22:27:36 +0100
commit55197ee34198b2ccbe8ccc57bac336b9dd42e31b (patch)
treef458b454ceed01cf0c408a9e3b2305c456a78bcc /examples
parent4b35ccab1fc614c766301d09ac07f0d6d799fe40 (diff)
downloadkombu-55197ee34198b2ccbe8ccc57bac336b9dd42e31b.tar.gz
master now depends on Python 2.7
Diffstat (limited to 'examples')
-rw-r--r--examples/simple_task_queue/worker.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py
index ded3aa73..6113d4ac 100644
--- a/examples/simple_task_queue/worker.py
+++ b/examples/simple_task_queue/worker.py
@@ -1,6 +1,6 @@
from kombu.mixins import ConsumerMixin
from kombu.log import get_logger
-from kombu.utils import kwdict, reprcall
+from kombu.utils import reprcall
from .queues import task_queues
@@ -23,7 +23,7 @@ class Worker(ConsumerMixin):
kwargs = body['kwargs']
logger.info('Got task: %s', reprcall(fun.__name__, args, kwargs))
try:
- fun(*args, **kwdict(kwargs))
+ fun(*args, **kwargs)
except Exception as exc:
logger.error('task raised exception: %r', exc)
message.ack()