Auto-fix lint and format issues

Author: octavia-squidington-iii

airbyte_cdk/sources/declarative/decoders/json_decoder.py

@@ -44,6 +44,7 @@ def decode(
         if not has_yielded:
             yield {}
 
+
 @dataclass
 class IterableDecoder(Decoder):
     """

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -2037,13 +2037,15 @@ def create_json_decoder(model: JsonDecoderModel, config: Config, **kwargs: Any)
 
     @staticmethod
     def create_csv_decoder(model: CsvDecoderModel, config: Config, **kwargs: Any) -> Decoder:
-        return CompositeRawDecoder(parser=ModelToComponentFactory._get_parser(model, config), stream_response=False)
+        return CompositeRawDecoder(
+            parser=ModelToComponentFactory._get_parser(model, config), stream_response=False
+        )
 
     @staticmethod
-    def create_jsonl_decoder(
-        model: JsonlDecoderModel, config: Config, **kwargs: Any
-    ) -> Decoder:
-        return CompositeRawDecoder(parser=ModelToComponentFactory._get_parser(model, config), stream_response=True)
+    def create_jsonl_decoder(model: JsonlDecoderModel, config: Config, **kwargs: Any) -> Decoder:
+        return CompositeRawDecoder(
+            parser=ModelToComponentFactory._get_parser(model, config), stream_response=True
+        )
 
     @staticmethod
     def create_iterable_decoder(
@@ -2070,8 +2072,12 @@ def _get_parser(model: BaseModel, config: Config) -> Parser:
         elif isinstance(model, CsvDecoderModel):
             return CsvParser(encoding=model.encoding, delimiter=model.delimiter)
         elif isinstance(model, GzipDecoderModel):
-            return GzipParser(inner_parser=ModelToComponentFactory._get_parser(model.inner_decoder, config))
-        elif isinstance(model, (CustomDecoderModel, IterableDecoderModel, XmlDecoderModel, ZipfileDecoderModel)):
+            return GzipParser(
+                inner_parser=ModelToComponentFactory._get_parser(model.inner_decoder, config)
+            )
+        elif isinstance(
+            model, (CustomDecoderModel, IterableDecoderModel, XmlDecoderModel, ZipfileDecoderModel)
+        ):
             raise ValueError(f"Decoder type {model} does not have parser associated to it")
 
         raise ValueError(f"Unknown decoder type {model}")

unit_tests/sources/declarative/auth/test_token_provider.py

@@ -55,9 +55,9 @@ def test_session_token_provider_cache_expiration():
         provider = create_session_token_provider()
         provider.get_token()
 
-    provider.login_requester.send_request.return_value.content = json.dumps({
-        "nested": {"token": "updated_token"}
-    }).encode()
+    provider.login_requester.send_request.return_value.content = json.dumps(
+        {"nested": {"token": "updated_token"}}
+    ).encode()
 
     with freezegun.freeze_time("2001-05-21T14:00:00Z"):
         assert provider.get_token() == "updated_token"

unit_tests/sources/declarative/decoders/test_composite_decoder.py

@@ -201,7 +201,9 @@ def test_composite_raw_decoder_csv_parser_values(requests_mock, encoding: str, d
 
 
 def test_given_response_already_consumed_when_decode_then_no_data_is_returned(requests_mock):
-    requests_mock.register_uri("GET", "https://airbyte.io/", content=json.dumps({"test": "test"}).encode())
+    requests_mock.register_uri(
+        "GET", "https://airbyte.io/", content=json.dumps({"test": "test"}).encode()
+    )
     response = requests.get("https://airbyte.io/", stream=True)
     composite_raw_decoder = CompositeRawDecoder(parser=JsonParser(encoding="utf-8"))
 
@@ -212,10 +214,16 @@ def test_given_response_already_consumed_when_decode_then_no_data_is_returned(re
         list(composite_raw_decoder.decode(response))
 
 
-def test_given_response_is_not_streamed_when_decode_then_can_be_called_multiple_times(requests_mock):
-    requests_mock.register_uri("GET", "https://airbyte.io/", content=json.dumps({"test": "test"}).encode())
+def test_given_response_is_not_streamed_when_decode_then_can_be_called_multiple_times(
+    requests_mock,
+):
+    requests_mock.register_uri(
+        "GET", "https://airbyte.io/", content=json.dumps({"test": "test"}).encode()
+    )
     response = requests.get("https://airbyte.io/")
-    composite_raw_decoder = CompositeRawDecoder(parser=JsonParser(encoding="utf-8"), stream_response=False)
+    composite_raw_decoder = CompositeRawDecoder(
+        parser=JsonParser(encoding="utf-8"), stream_response=False
+    )
 
     content = list(composite_raw_decoder.decode(response))
     content_second_time = list(composite_raw_decoder.decode(response))

unit_tests/sources/declarative/decoders/test_json_decoder.py

@@ -42,7 +42,10 @@ def test_json_decoder(requests_mock, response_body, first_element):
 def test_jsonl_decoder(requests_mock, response_body, expected_json):
     requests_mock.register_uri("GET", "https://airbyte.io/", text=response_body)
     response = requests.get("https://airbyte.io/", stream=True)
-    assert list(CompositeRawDecoder(parser=JsonLineParser(), stream_response=True).decode(response)) == expected_json
+    assert (
+        list(CompositeRawDecoder(parser=JsonLineParser(), stream_response=True).decode(response))
+        == expected_json
+    )
 
 
 @pytest.fixture(name="large_events_response")