diff options
| author | Ask Solem <ask@celeryproject.org> | 2015-07-13 12:22:16 -0700 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2015-07-13 12:22:16 -0700 |
| commit | 4ef2f10e15a784de56dcd290d60229020ab11090 (patch) | |
| tree | 417106713d6886466a8e734b53493a966ab9896f /examples | |
| parent | d1decb5033fffc12cbd370b483ce81bbe6e42bc4 (diff) | |
| download | kombu-4ef2f10e15a784de56dcd290d60229020ab11090.tar.gz | |
Single item tuples no longer require whitespace
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/complete_receive.py | 6 | ||||
| -rw-r--r-- | examples/experimental/async_consume.py | 2 | ||||
| -rw-r--r-- | examples/simple_eventlet_send.py | 2 | ||||
| -rw-r--r-- | examples/simple_task_queue/client.py | 2 | ||||
| -rw-r--r-- | examples/simple_task_queue/tasks.py | 2 |
5 files changed, 7 insertions, 7 deletions
diff --git a/examples/complete_receive.py b/examples/complete_receive.py index 30d4d461..eb774476 100644 --- a/examples/complete_receive.py +++ b/examples/complete_receive.py @@ -17,9 +17,9 @@ def pretty(obj): #: This is the callback applied when a message is received. def handle_message(body, message): - print('Received message: %r' % (body, )) - print(' properties:\n%s' % (pretty(message.properties), )) - print(' delivery_info:\n%s' % (pretty(message.delivery_info), )) + print('Received message: %r' % (body,)) + print(' properties:\n%s' % (pretty(message.properties),)) + print(' delivery_info:\n%s' % (pretty(message.delivery_info),)) message.ack() #: Create a connection and a channel. diff --git a/examples/experimental/async_consume.py b/examples/experimental/async_consume.py index 1a15c7a9..232292ae 100644 --- a/examples/experimental/async_consume.py +++ b/examples/experimental/async_consume.py @@ -15,7 +15,7 @@ def send_message(conn): def on_message(message): - print('RECEIVED: %r' % (message.body, )) + print('RECEIVED: {0!r}'.format(message.body)) message.ack() hub.stop() # <-- exit after one message diff --git a/examples/simple_eventlet_send.py b/examples/simple_eventlet_send.py index c2b3690d..6c3ef003 100644 --- a/examples/simple_eventlet_send.py +++ b/examples/simple_eventlet_send.py @@ -28,7 +28,7 @@ def send_many(n): with connection.SimpleQueue('kombu_demo') as queue: def send_message(i): - queue.put({'hello': 'world%s' % (i, )}) + queue.put({'hello': 'world%s' % (i,)}) pool = eventlet.GreenPool(10) for i in range(n): diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py index 0c28932b..1b249578 100644 --- a/examples/simple_task_queue/client.py +++ b/examples/simple_task_queue/client.py @@ -24,5 +24,5 @@ if __name__ == '__main__': from .tasks import hello_task connection = Connection('amqp://guest:guest@localhost:5672//') - send_as_task(connection, fun=hello_task, args=('Kombu', ), kwargs={}, + send_as_task(connection, fun=hello_task, args=('Kombu',), kwargs={}, priority='high') diff --git a/examples/simple_task_queue/tasks.py b/examples/simple_task_queue/tasks.py index f6e9da03..7f604c3c 100644 --- a/examples/simple_task_queue/tasks.py +++ b/examples/simple_task_queue/tasks.py @@ -1,2 +1,2 @@ def hello_task(who="world"): - print("Hello %s" % (who, )) + print("Hello {0}".format(who)) |