diff --git a/elasticsearch/_async/http_aiohttp.py b/elasticsearch/_async/http_aiohttp.py
index 62b8c805..16576a8e 100644
--- a/elasticsearch/_async/http_aiohttp.py
+++ b/elasticsearch/_async/http_aiohttp.py
@@ -312,7 +312,9 @@ class AIOHttpConnection(Connection):
             cookie_jar=aiohttp.DummyCookieJar(),
             response_class=ESClientResponse,
             connector=aiohttp.TCPConnector(
-                limit=self._limit, use_dns_cache=True, ssl=self._ssl_context,
+                limit=self._limit,
+                use_dns_cache=True,
+                ssl=self._ssl_context,
             ),
         )
 
diff --git a/elasticsearch/connection/http_requests.py b/elasticsearch/connection/http_requests.py
index 4b5b81d1..e3685111 100644
--- a/elasticsearch/connection/http_requests.py
+++ b/elasticsearch/connection/http_requests.py
@@ -110,7 +110,10 @@ class RequestsHttpConnection(Connection):
                 http_auth = tuple(http_auth.split(":", 1))
             self.session.auth = http_auth
 
-        self.base_url = "%s%s" % (self.host, self.url_prefix,)
+        self.base_url = "%s%s" % (
+            self.host,
+            self.url_prefix,
+        )
         self.session.verify = verify_certs
         if not client_key:
             self.session.cert = client_cert
diff --git a/elasticsearch/exceptions.py b/elasticsearch/exceptions.py
index 5436c04b..5da15889 100644
--- a/elasticsearch/exceptions.py
+++ b/elasticsearch/exceptions.py
@@ -154,7 +154,7 @@ class AuthorizationException(TransportError):
 
 
 class ElasticsearchDeprecationWarning(Warning):
-    """ Warning that is raised when a deprecated option
+    """Warning that is raised when a deprecated option
     is flagged via the 'Warning' HTTP header.
     """
 
diff --git a/test_elasticsearch/test_connection.py b/test_elasticsearch/test_connection.py
index 4727f6d1..a3bc7810 100644
--- a/test_elasticsearch/test_connection.py
+++ b/test_elasticsearch/test_connection.py
@@ -534,7 +534,9 @@ class TestRequestsConnection(TestCase):
         self.assertNotIn("accept-encoding", req.headers)
 
     def test_http_compression(self):
-        con = self._get_mock_connection({"http_compress": True},)
+        con = self._get_mock_connection(
+            {"http_compress": True},
+        )
 
         self.assertTrue(con.http_compress)
 
diff --git a/test_elasticsearch/test_serializer.py b/test_elasticsearch/test_serializer.py
index 0350dac1..a22c3784 100644
--- a/test_elasticsearch/test_serializer.py
+++ b/test_elasticsearch/test_serializer.py
@@ -108,7 +108,8 @@ class TestJSONSerializer(TestCase):
 
     def test_serializes_numpy_nan_to_nan(self):
         self.assertEqual(
-            '{"d":NaN}', JSONSerializer().dumps({"d": np.nan}),
+            '{"d":NaN}',
+            JSONSerializer().dumps({"d": np.nan}),
         )
 
     def test_serializes_pandas_timestamp(self):
@@ -127,7 +128,8 @@ class TestJSONSerializer(TestCase):
         if not hasattr(pd, "NA"):  # pandas.NA added in v1
             raise SkipTest("pandas.NA required")
         self.assertEqual(
-            '{"d":null}', JSONSerializer().dumps({"d": pd.NA}),
+            '{"d":null}',
+            JSONSerializer().dumps({"d": pd.NA}),
         )
 
     def test_raises_serialization_error_pandas_nat(self):
@@ -138,12 +140,14 @@ class TestJSONSerializer(TestCase):
     def test_serializes_pandas_category(self):
         cat = pd.Categorical(["a", "c", "b", "a"], categories=["a", "b", "c"])
         self.assertEqual(
-            '{"d":["a","c","b","a"]}', JSONSerializer().dumps({"d": cat}),
+            '{"d":["a","c","b","a"]}',
+            JSONSerializer().dumps({"d": cat}),
         )
 
         cat = pd.Categorical([1, 2, 3], categories=[1, 2, 3])
         self.assertEqual(
-            '{"d":[1,2,3]}', JSONSerializer().dumps({"d": cat}),
+            '{"d":[1,2,3]}',
+            JSONSerializer().dumps({"d": cat}),
         )
 
     def test_raises_serialization_error_on_dump_error(self):