summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2013-02-07 15:38:15 +0000
committerAsk Solem <ask@celeryproject.org>2013-02-07 15:38:15 +0000
commit67d2fa4744f681a56cab69aa706cc3eb67bdd296 (patch)
tree5dde2591b2dae191740d478a0cd85dd075466270 /examples
parentcc8b99b237019d0904c3da05850895db6b924a75 (diff)
parent7c5dc19be1953e94fdf04adf016f91292677e144 (diff)
downloadkombu-67d2fa4744f681a56cab69aa706cc3eb67bdd296.tar.gz
Merge branch '2.5'
Conflicts: pavement.py
Diffstat (limited to 'examples')
-rw-r--r--examples/simple_task_queue/client.py9
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