Merge branch 'main' into swathipil/eh/sslcontext-kwarg

sdk/eventhub/azure-eventhub/azure/eventhub/_configuration.py

@@ -17,30 +17,30 @@
 
 class Configuration:  # pylint:disable=too-many-instance-attributes
     def __init__(
-            self,  # pylint:disable=unused-argument
-            *,
-            hostname: str,
-            amqp_transport: Union["AmqpTransport", "AmqpTransportAsync"],
-            socket_timeout: Optional[float] = None,
-            user_agent: Optional[str] = None,
-            retry_total: int = 3,
-            retry_mode: Union[str, RetryMode] = RetryMode.Exponential,
-            retry_backoff_factor: float = 0.8,
-            retry_backoff_max: int = 120,
-            network_tracing: bool = False,
-            http_proxy: Optional[Dict[str, Any]] = None,
-            transport_type: TransportType = TransportType.Amqp,
-            auth_timeout: int = 60,
-            prefetch: int = 300,
-            max_batch_size: int = 300,
-            receive_timeout: int = 0,
-            send_timeout: int = 60,
-            custom_endpoint_address: Optional[str] = None,
-            connection_verify: Optional[str] = None,
-            use_tls: bool = True,
-            ssl_context: Optional["SSLContext"] = None,
-            **kwargs: Any
-        ):
+        self,  # pylint:disable=unused-argument
+        *,
+        hostname: str,
+        amqp_transport: Union["AmqpTransport", "AmqpTransportAsync"],
+        socket_timeout: Optional[float] = None,
+        user_agent: Optional[str] = None,
+        retry_total: int = 3,
+        retry_mode: Union[str, RetryMode] = RetryMode.Exponential,
+        retry_backoff_factor: float = 0.8,
+        retry_backoff_max: int = 120,
+        network_tracing: bool = False,
+        http_proxy: Optional[Dict[str, Any]] = None,
+        transport_type: TransportType = TransportType.Amqp,
+        auth_timeout: int = 60,
+        prefetch: int = 300,
+        max_batch_size: int = 300,
+        receive_timeout: int = 0,
+        send_timeout: int = 60,
+        custom_endpoint_address: Optional[str] = None,
+        connection_verify: Optional[str] = None,
+        ssl_context: Optional["SSLContext"] = None,
+        use_tls: bool = True,
+        **kwargs: Any
+    ):
         self.user_agent = user_agent
         self.retry_total = retry_total
         self.max_retries = self.retry_total

sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_transport.py

@@ -171,7 +171,7 @@ def __init__(
         socket_settings=None,
         raise_on_initial_eintr=True,
         use_tls: bool = True,
-        **kwargs
+        **kwargs,
     ):
         self._quick_recv = None
         self.connected = False

sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/aio/_transport_async.py

@@ -41,6 +41,7 @@
 from io import BytesIO
 import logging
 
+
 from .._platform import KNOWN_TCP_OPTS, SOL_TCP
 from .._encode import encode_frame
 from .._decode import decode_frame, decode_empty_frame

sdk/eventhub/azure-eventhub/tests/conftest.py

@@ -60,10 +60,12 @@ def sleep(request):
 def uamqp_transport(request):
     return request.param
 
+
 @pytest.fixture(scope="session", params=socket_transports, ids=socket_transport_ids)
 def socket_transport(request):
     return request.param
 
+
 @pytest.fixture(scope="session")    
 def storage_url():
     try: