- Fixed lint.

issue #283

Author: albamig

packages/plugins/minos-broker-rabbitmq/HISTORY.md

@@ -1,16 +1,5 @@
 # History
 
-## 0.5.0 (2022-02-03)
+## 0.6.0 (2022-03-25)
 
-* Migrate `PostgreSqlQueuedKafkaBrokerPublisher` from `minos-microservice-networks`.
-* Migrate `InMemoryQueuedKafkaBrokerPublisher` from `minos-microservice-networks`.
-* Migrate `KafkaBrokerPublisher` from `minos-microservice-networks`.
-* Migrate `KafkaBrokerSubscriber` from `minos-microservice-networks`.
-* Migrate `KafkaBrokerSubscriberBuilder` from `minos-microservice-networks`.
-* Migrate `PostgreSqlQueuedKafkaBrokerSubscriberBuilder` from `minos-microservice-networks`.
-* Migrate `InMemoryQueuedKafkaBrokerSubscriberBuilder` from `minos-microservice-networks`.
-* Minor changes.
-
-## 0.5.1 (2022-02-03)
-
-* Fix bug related with dependency specification.
+* Created RabbitMQ plugin.

packages/plugins/minos-broker-rabbitmq/tests/test_rabbitmq/test_integration.py

@@ -1,4 +1,3 @@
-import asyncio
 from unittest import (
     IsolatedAsyncioTestCase,
 )
@@ -30,4 +29,4 @@ async def test_one_topic(self):
 
     async def test_empty_topic(self):
         async with RabbitMQBrokerSubscriber.from_config(CONFIG_FILE_PATH, topics={"empty_topic"}) as subscriber:
-            observed = await subscriber.receive()
+            await subscriber.receive()

packages/plugins/minos-broker-rabbitmq/tests/test_rabbitmq/test_publisher.py

@@ -1,17 +1,12 @@
 import unittest
 from unittest.mock import (
-    AsyncMock,
     patch,
 )
 
-import aio_pika
-
 from minos.common import (
     Config,
-    MinosConfig,
 )
 from minos.networks import (
-    BrokerMessage,
     BrokerMessageV1,
     BrokerMessageV1Payload,
     BrokerPublisher,

packages/plugins/minos-broker-rabbitmq/tests/test_rabbitmq/test_subscriber.py

@@ -3,18 +3,13 @@
     namedtuple,
 )
 from unittest.mock import (
-    AsyncMock,
-    MagicMock,
     patch,
 )
 
 from minos.common import (
     Config,
-    MinosConfig,
 )
 from minos.networks import (
-    BrokerMessageV1,
-    BrokerMessageV1Payload,
     BrokerSubscriber,
     InMemoryBrokerSubscriberQueue,
     PostgreSqlBrokerSubscriberQueue,
@@ -50,11 +45,6 @@ async def test_from_config(self):
     @patch("minos.plugins.rabbitmq.subscriber.connect")
     @patch("minos.networks.BrokerMessage.from_avro_bytes")
     async def test_receive(self, connect_mock, mock_avro):
-        messages = [
-            BrokerMessageV1("foo", BrokerMessageV1Payload("bar")),
-            BrokerMessageV1("bar", BrokerMessageV1Payload("foo")),
-        ]
-
         async with RabbitMQBrokerSubscriber.from_config(CONFIG_FILE_PATH, topics={"foo", "bar"}) as subscriber:
             await subscriber.receive()