summaryrefslogtreecommitdiff
path: root/examples/simple_task_queue
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2012-11-13 13:44:41 +0000
committerAsk Solem <ask@celeryproject.org>2012-11-13 13:44:41 +0000
commitf42e5597e110add2a4f1e9102f0844fbdc71cc2c (patch)
treee2e29b85b5cb283447f1540a4cfc826a0dfac5eb /examples/simple_task_queue
parentc73865812d55f57a3a1893ebde7a2d304357e4e0 (diff)
downloadkombu-f42e5597e110add2a4f1e9102f0844fbdc71cc2c.tar.gz
Revert 7f9b38f... [kombu3] No longer supports Python 2.5
Diffstat (limited to 'examples/simple_task_queue')
-rw-r--r--examples/simple_task_queue/client.py2
-rw-r--r--examples/simple_task_queue/worker.py4
2 files changed, 5 insertions, 1 deletions
diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py
index 8ed33f36..fe0a512b 100644
--- a/examples/simple_task_queue/client.py
+++ b/examples/simple_task_queue/client.py
@@ -1,3 +1,5 @@
+from __future__ import with_statement
+
from kombu.common import maybe_declare
from kombu.pools import producers
diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py
index 807542e9..be241140 100644
--- a/examples/simple_task_queue/worker.py
+++ b/examples/simple_task_queue/worker.py
@@ -1,3 +1,5 @@
+from __future__ import with_statement
+
from kombu.mixins import ConsumerMixin
from kombu.log import get_logger
from kombu.utils import kwdict, reprcall
@@ -23,7 +25,7 @@ class Worker(ConsumerMixin):
logger.info('Got task: %s', reprcall(fun.__name__, args, kwargs))
try:
fun(*args, **kwdict(kwargs))
- except Exception as exc:
+ except Exception, exc:
logger.error('task raised exception: %r', exc)
message.ack()