From 86274e967d900077f5e509d436d92f5a5db34b63 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Tue, 27 May 2014 14:41:20 +0100 Subject: Fixes flakes after flake8 upgrade --- examples/experimental/async_consume.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'examples') diff --git a/examples/experimental/async_consume.py b/examples/experimental/async_consume.py index 1127128a..1a15c7a9 100644 --- a/examples/experimental/async_consume.py +++ b/examples/experimental/async_consume.py @@ -2,12 +2,12 @@ from kombu import Connection, Exchange, Queue, Producer, Consumer from kombu.async import Hub -from threading import Event hub = Hub() exchange = Exchange('asynt') queue = Queue('asynt', exchange, 'asynt') + def send_message(conn): producer = Producer(conn) producer.publish('hello world', exchange=exchange, routing_key='asynt') -- cgit v1.2.1