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}