diff --git a/amqtt/client.py b/amqtt/client.py
index a11c5af..c01e347 100644
--- a/amqtt/client.py
+++ b/amqtt/client.py
@@ -456,7 +456,7 @@ class MQTTClient:
         # if not self._handler:
         self._handler = ClientProtocolHandler(self.plugins_manager)
 
-        connection_timeout = self.config.get('connection_timeout', None)
+        connection_timeout = self.config.get("connection_timeout", None)
 
         if secure:
             sc = ssl.create_default_context(
@@ -480,10 +480,10 @@ class MQTTClient:
             if scheme in ("mqtt", "mqtts"):
                 conn_reader, conn_writer = await asyncio.wait_for(
                     asyncio.open_connection(
-                    self.session.remote_address,
-                    self.session.remote_port,
-                    **kwargs,
-                ), timeout=connection_timeout)
+                        self.session.remote_address,
+                        self.session.remote_port,
+                        **kwargs,
+                    ), timeout=connection_timeout)
 
                 reader = StreamReaderAdapter(conn_reader)
                 writer = StreamWriterAdapter(conn_writer)