diff options
| author | Ask Solem <ask@celeryproject.org> | 2013-01-17 13:50:01 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2013-01-17 13:50:01 +0000 |
| commit | dd0fe3a3a6a1bb50209e697d7bef91473661bee2 (patch) | |
| tree | 051c6aca716911da80a482049aad4373c049c222 /examples | |
| parent | 02cd13bc9eec102bf0752a9e4ab3fe7cae078cd8 (diff) | |
| download | kombu-dd0fe3a3a6a1bb50209e697d7bef91473661bee2.tar.gz | |
More pep8ify
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 fe0a512b..b4731061 100644 --- a/examples/simple_task_queue/client.py +++ b/examples/simple_task_queue/client.py @@ -16,10 +16,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 |