Skip to content

Commit a131abb

Browse files
committed
Merge remote-tracking branch 'origin/283-create-rabbitmq-plugin' into 283-create-rabbitmq-plugin
2 parents 2e58cce + 2eebaf9 commit a131abb

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

packages/plugins/minos-broker-rabbitmq/minos/plugins/rabbitmq/subscriber.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,9 @@
1313
from aio_pika import (
1414
connect,
1515
)
16-
from aio_pika.exceptions import QueueEmpty
16+
from aio_pika.exceptions import (
17+
QueueEmpty,
18+
)
1719

1820
from minos.common import (
1921
Config,

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,4 +31,3 @@ async def test_one_topic(self):
3131
async def test_empty_topic(self):
3232
async with RabbitMQBrokerSubscriber.from_config(CONFIG_FILE_PATH, topics={"empty_topic"}) as subscriber:
3333
observed = await subscriber.receive()
34-

0 commit comments

Comments
 (0)