format

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

examples/getting_started/getting_started.py

@@ -13,7 +13,10 @@
     OutcomeState,
     QuorumQueueSpecification,
 )
-from rabbitmq_amqp_python_client.utils import string_to_bytes, bytes_to_string
+from rabbitmq_amqp_python_client.utils import (
+    bytes_to_string,
+    string_to_bytes,
+)
 
 MESSAGES_TO_PUBLISH = 100
 

rabbitmq_amqp_python_client/qpid/proton/_message.py

@@ -84,7 +84,11 @@
 from ._common import millis2secs, secs2millis
 from ._data import AnnotationDict, Data, char, symbol, ulong
 from ._endpoints import Link
-from ._exceptions import EXCEPTIONS, MessageException, ArgumentOutOfRangeException
+from ._exceptions import (
+    EXCEPTIONS,
+    ArgumentOutOfRangeException,
+    MessageException,
+)
 
 if TYPE_CHECKING:
     from proton._data import Described, PythonAMQPData

rabbitmq_amqp_python_client/qpid/proton/_tracing.py

@@ -32,8 +32,10 @@
 
 import proton
 from proton import Sender as ProtonSender
-from proton.handlers import IncomingMessageHandler as ProtonIncomingMessageHandler
-from proton.handlers import OutgoingMessageHandler as ProtonOutgoingMessageHandler
+from proton.handlers import \
+    IncomingMessageHandler as ProtonIncomingMessageHandler
+from proton.handlers import \
+    OutgoingMessageHandler as ProtonOutgoingMessageHandler
 
 _tracer = None
 _trace_key = proton.symbol("x-opt-qpid-tracestate")

rabbitmq_amqp_python_client/qpid/proton/_transport.py

@@ -139,7 +139,8 @@
 
 if TYPE_CHECKING:
     from ._condition import Condition
-    from ._endpoints import Connection  # would produce circular import
+    from ._endpoints import \
+        Connection  # would produce circular import
 
 
 class TraceAdapter:

tests/test_consumer.py

@@ -5,7 +5,9 @@
     Environment,
     QuorumQueueSpecification,
 )
-from rabbitmq_amqp_python_client.utils import bytes_to_string
+from rabbitmq_amqp_python_client.utils import (
+    bytes_to_string,
+)
 
 from .conftest import (
     ConsumerTestException,

tests/test_publisher.py

@@ -13,7 +13,9 @@
     StreamSpecification,
     ValidationCodeException,
 )
-from rabbitmq_amqp_python_client.utils import string_to_bytes
+from rabbitmq_amqp_python_client.utils import (
+    string_to_bytes,
+)
 
 from .http_requests import delete_all_connections
 from .utils import create_binding, publish_per_message

tests/utils.py

@@ -16,7 +16,9 @@
     Publisher,
     QuorumQueueSpecification,
 )
-from rabbitmq_amqp_python_client.utils import string_to_bytes
+from rabbitmq_amqp_python_client.utils import (
+    string_to_bytes,
+)
 
 
 def publish_messages(