Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Dec 5, 2024
1 parent 6d7b2fd commit f5f43c1
Showing 1 changed file with 5 additions and 12 deletions.
17 changes: 5 additions & 12 deletions t/integration/test_py_amqp.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down Expand Up @@ -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(
Expand All @@ -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
Expand Down

0 comments on commit f5f43c1

Please sign in to comment.