From e5a4e7e99457541cbd94e898d9d3434ed4859d07 Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Mon, 16 May 2022 15:00:09 +0200 Subject: [PATCH] applied black --- pyinfra/server/receiver/receiver.py | 1 - pyinfra/server/utils.py | 2 -- test/unit_tests/server/pipeline_test.py | 1 - test/unit_tests/server/stream_buffer_test.py | 4 +++- 4 files changed, 3 insertions(+), 5 deletions(-) diff --git a/pyinfra/server/receiver/receiver.py b/pyinfra/server/receiver/receiver.py index 27b6d06..192579f 100644 --- a/pyinfra/server/receiver/receiver.py +++ b/pyinfra/server/receiver/receiver.py @@ -3,7 +3,6 @@ from typing import Iterable class Receiver(abc.ABC): - @abc.abstractmethod def __call__(self, package: Iterable): pass diff --git a/pyinfra/server/utils.py b/pyinfra/server/utils.py index e06e78d..57c2fa1 100644 --- a/pyinfra/server/utils.py +++ b/pyinfra/server/utils.py @@ -13,5 +13,3 @@ def make_streamable_and_wrap_in_packing_logic(fn, batched): def make_streamable(fn, batched): return compose(normalize, (identity if batched else starlift)(fn)) - - diff --git a/test/unit_tests/server/pipeline_test.py b/test/unit_tests/server/pipeline_test.py index c15163e..5505223 100644 --- a/test/unit_tests/server/pipeline_test.py +++ b/test/unit_tests/server/pipeline_test.py @@ -40,7 +40,6 @@ def test_pipeline(core_operation, client_pipeline, input_data_items, metadata, t assert output == targets - # @pytest.mark.parametrize("item_type", ["string"]) # @pytest.mark.parametrize("n_items", [1]) # def test_pipeline_is_lazy(input_data_items, metadata): diff --git a/test/unit_tests/server/stream_buffer_test.py b/test/unit_tests/server/stream_buffer_test.py index 2a39190..962257b 100644 --- a/test/unit_tests/server/stream_buffer_test.py +++ b/test/unit_tests/server/stream_buffer_test.py @@ -39,7 +39,9 @@ def test_flat_stream_buffer(func, inputs, outputs, buffer_size): assert list(flat_stream_buffer([])) == [] -def test_flat_stream_buffer_on_different_data(core_operation, input_data_items, target_data_items, buffer_size, item_type, one_to_many): +def test_flat_stream_buffer_on_different_data( + core_operation, input_data_items, target_data_items, buffer_size, item_type, one_to_many +): if core_operation is Nothing: pytest.skip(f"No operation defined for parameter combination: {item_type=}, {one_to_many=}")