From fabc78efcef99fd674c9d4fd2ea68cc13ca1d84d Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Wed, 27 Apr 2022 13:41:48 +0200 Subject: [PATCH] refactoring; formatting --- test/exploration_tests/partial_response_test.py | 1 - test/fixtures/server.py | 7 ++----- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/test/exploration_tests/partial_response_test.py b/test/exploration_tests/partial_response_test.py index fbb3d3c..f02a671 100644 --- a/test/exploration_tests/partial_response_test.py +++ b/test/exploration_tests/partial_response_test.py @@ -15,7 +15,6 @@ def lift(fn): def send_partial_request(url, input_data: Iterable[bytes], metadata): - def pack(data: bytes): package = {"data": bytes_to_string(data), "metadata": metadata} package = json.dumps(package).encode() diff --git a/test/fixtures/server.py b/test/fixtures/server.py index 06b8e67..e46f259 100644 --- a/test/fixtures/server.py +++ b/test/fixtures/server.py @@ -46,21 +46,18 @@ def processor_fn(item_type, data_items): def make_string_processor(): - def processor_fn(request: flask.Request, buffersize=3): + def processor_fn(request: flask.Request, buffer_size=3): data = get_data_from_request(request) - if not data or len(buffer) == buffersize: - + if not data or len(buffer) == buffer_size: result = [bytes_to_string(itm.decode().upper().encode()) for itm in buffer] - buffer.clear() else: result = [] if data: - buffer.append(data) response_payload = {"data": result}