From 28f3380c4b563d87935571faaf9a64cc323c449b Mon Sep 17 00:00:00 2001 From: Oleg A Date: Sat, 18 Feb 2023 15:14:39 +0300 Subject: [PATCH 1/2] fix: queue_name was set as channel_name --- aio_pika/patterns/master.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/aio_pika/patterns/master.py b/aio_pika/patterns/master.py index 705ff597..0c79a718 100644 --- a/aio_pika/patterns/master.py +++ b/aio_pika/patterns/master.py @@ -169,16 +169,16 @@ async def on_message( await message.nack(requeue=e.requeue) async def create_queue( - self, channel_name: str, **kwargs: Any, + self, queue_name: str, **kwargs: Any, ) -> AbstractQueue: - return await self.channel.declare_queue(channel_name, **kwargs) + return await self.channel.declare_queue(queue_name, **kwargs) async def create_worker( - self, channel_name: str, func: Callable[..., Any], **kwargs: Any, + self, queue_name: str, func: Callable[..., Any], **kwargs: Any, ) -> Worker: """ Creates a new :class:`Worker` instance. """ - queue = await self.create_queue(channel_name, **kwargs) + queue = await self.create_queue(queue_name, **kwargs) if hasattr(func, "_is_coroutine"): fn = func From 1b927b3c27f91d9a91136af3c184f29a5d89bbea Mon Sep 17 00:00:00 2001 From: Mosquito Date: Sat, 18 Feb 2023 23:46:57 +0300 Subject: [PATCH 2/2] fix coveralls --- .github/workflows/tests.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml index d4bd7e6b..a62002d1 100644 --- a/.github/workflows/tests.yml +++ b/.github/workflows/tests.yml @@ -96,7 +96,7 @@ jobs: - run: poetry run coveralls env: COVERALLS_PARALLEL: 'true' - COVERALLS_REPO_TOKEN: ${{ secrets.COVERALLS_REPO_TOKEN }} + COVERALLS_SERVICE_NAME: github GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} finish: