From f5f43c1b3cae5a64b0ec4c6e108267ad4becbb41 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Thu, 5 Dec 2024 20:41:48 +0000 Subject: [PATCH] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- t/integration/test_py_amqp.py | 17 +++++------------ 1 file changed, 5 insertions(+), 12 deletions(-) diff --git a/t/integration/test_py_amqp.py b/t/integration/test_py_amqp.py index 52682ce84..97660405c 100644 --- a/t/integration/test_py_amqp.py +++ b/t/integration/test_py_amqp.py @@ -4,20 +4,13 @@ import uuid import pytest - -import kombu from amqp.exceptions import NotFound +import kombu from kombu.connection import ConnectionPool -from .common import ( - BaseExchangeTypes, - BaseFailover, - BaseMessage, - BasePriority, - BaseTimeToLive, - BasicFunctionality, -) +from .common import (BaseExchangeTypes, BaseFailover, BaseMessage, + BasePriority, BaseTimeToLive, BasicFunctionality) def get_connection(hostname, port, vhost): @@ -117,7 +110,7 @@ def test_publish_confirm_does_not_block(self, confirm_publish_connection): with pool.acquire(block=True) as connection: producer = kombu.Producer(connection) queue = kombu.Queue( - "test-queue-{}".format(uuid.uuid4()), channel=connection + f"test-queue-{uuid.uuid4()}", channel=connection ) queue.declare() producer.publish( @@ -134,7 +127,7 @@ def test_publish_confirm_does_not_block(self, confirm_publish_connection): with pool.acquire(block=True) as connection: producer = kombu.Producer(connection) queue = kombu.Queue( - "test-queue-{}".format(uuid.uuid4()), channel=connection + f"test-queue-{uuid.uuid4()}", channel=connection ) queue.declare() # In case the connection is broken, we should get a Timeout here