diff options
| author | Ask Solem <ask@celeryproject.org> | 2013-09-10 17:26:12 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2013-09-10 17:26:12 +0100 |
| commit | 554bddd2af198680b6e2ea5a4aa3448850e04c07 (patch) | |
| tree | c7bc069e196dc90aedf1bff31d8d1286f790b8da /examples/simple_task_queue | |
| parent | 2ff6f89c48143ae9101df91fe58cc61375aaca0b (diff) | |
| download | kombu-554bddd2af198680b6e2ea5a4aa3448850e04c07.tar.gz | |
Py3 fixes
Diffstat (limited to 'examples/simple_task_queue')
| -rw-r--r-- | examples/simple_task_queue/client.py | 4 | ||||
| -rw-r--r-- | examples/simple_task_queue/worker.py | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py index 2cbd8f92..8e14381f 100644 --- a/examples/simple_task_queue/client.py +++ b/examples/simple_task_queue/client.py @@ -1,7 +1,7 @@ from kombu.common import maybe_declare from kombu.pools import producers -from queues import task_exchange +from .queues import task_exchange priority_to_routing_key = {'high': 'hipri', 'mid': 'midpri', @@ -22,7 +22,7 @@ def send_as_task(connection, fun, args=(), kwargs={}, priority='mid'): if __name__ == '__main__': from kombu import Connection - from tasks import hello_task + from .tasks import hello_task connection = Connection('amqp://guest:guest@localhost:5672//') send_as_task(connection, fun=hello_task, args=('Kombu', ), kwargs={}, diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py index 7f62445d..ded3aa73 100644 --- a/examples/simple_task_queue/worker.py +++ b/examples/simple_task_queue/worker.py @@ -2,7 +2,7 @@ from kombu.mixins import ConsumerMixin from kombu.log import get_logger from kombu.utils import kwdict, reprcall -from queues import task_queues +from .queues import task_queues logger = get_logger(__name__) |