diff options
author | Ask Solem <ask@celeryproject.org> | 2013-02-07 15:38:15 +0000 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2013-02-07 15:38:15 +0000 |
commit | 67d2fa4744f681a56cab69aa706cc3eb67bdd296 (patch) | |
tree | 5dde2591b2dae191740d478a0cd85dd075466270 /examples | |
parent | cc8b99b237019d0904c3da05850895db6b924a75 (diff) | |
parent | 7c5dc19be1953e94fdf04adf016f91292677e144 (diff) | |
download | kombu-67d2fa4744f681a56cab69aa706cc3eb67bdd296.tar.gz |
Merge branch '2.5'
Conflicts:
pavement.py
Diffstat (limited to 'examples')
-rw-r--r-- | examples/simple_task_queue/client.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py index 8ed33f36..8cad069e 100644 --- a/examples/simple_task_queue/client.py +++ b/examples/simple_task_queue/client.py @@ -14,10 +14,11 @@ def send_as_task(connection, fun, args=(), kwargs={}, priority='mid'): with producers[connection].acquire(block=True) as producer: maybe_declare(task_exchange, producer.channel) - producer.publish(payload, serializer='pickle', - compression='bzip2', - exchange=task_exchange, - routing_key=routing_key) + producer.publish(payload, + serializer='pickle', + compression='bzip2', + exchange=task_exchange, + routing_key=routing_key) if __name__ == '__main__': from kombu import Connection |