Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

refactoring; formatting

Browse Source
This commit is contained in:
Matthias Bisping 2022-04-27 13:41:48 +02:00
parent 90af62ed2c
commit fabc78efce
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
test/exploration_tests/partial_response_test.py
View File

@ -15,7 +15,6 @@ def lift(fn):
def send_partial_request(url, input_data: Iterable[bytes], metadata): def send_partial_request(url, input_data: Iterable[bytes], metadata):
def pack(data: bytes): def pack(data: bytes):
package = {"data": bytes_to_string(data), "metadata": metadata} package = {"data": bytes_to_string(data), "metadata": metadata}
package = json.dumps(package).encode() package = json.dumps(package).encode()

7
test/fixtures/server.py vendored
View File

@ -46,21 +46,18 @@ def processor_fn(item_type, data_items):
def make_string_processor(): 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) 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] result = [bytes_to_string(itm.decode().upper().encode()) for itm in buffer]
buffer.clear() buffer.clear()
else: else:
result = [] result = []
if data: if data:
buffer.append(data) buffer.append(data)
response_payload = {"data": result} response_payload = {"data": result}