Skip to content

Commit e4311af

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent db951b2 commit e4311af

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

unit_tests/sources/declarative/decoders/test_composite_decoder.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -222,7 +222,6 @@ def test_composite_raw_decoder_csv_parser_without_mocked_response():
222222
"""
223223
# self.wfile.write(bytes('John,Doe,120 jefferson st.,Riverside, NJ, 08075\nJack,McGinnis,220 hobo Av.,Phila, PA,09119\n"John ""Da Man""",Repici,120 Jefferson St.,Riverside, NJ,08075\nStephen,Tyler,"7452 Terrace ""At the Plaza"" road",SomeTown,SD, 91234\n,Blankman,,SomeTown, SD, 00298\n"Joan ""the bone"", Anne",Jet,"9th, at Terrace plc",Desert City,CO,00123\n', "utf-8"))
224224

225-
226225
# start server
227226
httpd = HTTPServer(("localhost", 8080), TestServer)
228227
thread = Thread(target=httpd.serve_forever, args=())
@@ -231,12 +230,13 @@ def test_composite_raw_decoder_csv_parser_without_mocked_response():
231230
try:
232231
response = requests.get(f"http://localhost:{port}", stream=True)
233232
result = list(CompositeRawDecoder(parser=CsvParser()).decode(response))
234-
233+
235234
assert len(result) == 1
236235
finally:
237236
httpd.shutdown() # release port and kill the thread
238237
thread.join(timeout=5) # ensure thread is cleaned up
239238

239+
240240
def test_given_response_already_consumed_when_decode_then_no_data_is_returned(requests_mock):
241241
requests_mock.register_uri(
242242
"GET", "https://airbyte.io/", content=json.dumps({"test": "test"}).encode()

0 commit comments

Comments
 (0)