[fix] fixes for linter

mosquito · Sep 8, 2017 · 512ddea · 512ddea
1 parent 48bba32
commit 512ddea
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/aio_pika/robust_channel.py b/aio_pika/robust_channel.py
@@ -1,9 +1,7 @@
 import asyncio
 from typing import Callable, Any, Generator, Union
 
-import pika.channel
 from logging import getLogger
-from types import FunctionType
 
 from aio_pika.tools import create_future
 from .compat import Awaitable

diff --git a/tests/test_amqp.py b/tests/test_amqp.py
@@ -815,7 +815,7 @@ def test_exchange_delete(self):
 
     @pytest.mark.asyncio
     def test_dlx(self):
-        client = yield from connect_robust(AMQP_URL, loop=self.loop)
+        client = yield from connect(AMQP_URL, loop=self.loop)
         suffix = self.get_random_name()
         routing_key = "%s_routing_key" % suffix
         dlx_routing_key = "%s_dlx_routing_key" % suffix

diff --git a/tests/test_amqp_robust.py b/tests/test_amqp_robust.py
@@ -896,7 +896,7 @@ def dlx_handle(message):
 
     @pytest.mark.asyncio
     @timeout()
-    def test_channel_close(self):
+    def test_channel_close_invalid_message(self):
         client = yield from connect_robust(AMQP_URL, loop=self.loop)  # type: aio_pika.connection.Connection
 
         routing_key = self.get_random_name()