diff options
| author | Ask Solem <ask@celeryproject.org> | 2012-11-13 13:44:41 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2012-11-13 13:44:41 +0000 |
| commit | f42e5597e110add2a4f1e9102f0844fbdc71cc2c (patch) | |
| tree | e2e29b85b5cb283447f1540a4cfc826a0dfac5eb /examples/simple_task_queue | |
| parent | c73865812d55f57a3a1893ebde7a2d304357e4e0 (diff) | |
| download | kombu-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.py | 2 | ||||
| -rw-r--r-- | examples/simple_task_queue/worker.py | 4 |
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() |
