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

refactoring

Browse Source
This commit is contained in:
Matthias Bisping 2022-05-16 13:04:37 +02:00
parent 7adbdefb4e
commit d12124b2d5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/unit_tests/server/pipeline_test.py
View File

@ -36,7 +36,6 @@ def pass_invalid_combination(fn):
return inner return inner
# @pass_invalid_combination
@pytest.mark.parametrize( @pytest.mark.parametrize(
"client_pipeline_type", "client_pipeline_type",
[ [
@ -45,13 +44,14 @@ def pass_invalid_combination(fn):
], ],
) )
def test_pipeline(core_operation, client_pipeline, input_data_items, metadata, targets, item_type, one_to_many): def test_pipeline(core_operation, client_pipeline, input_data_items, metadata, targets, item_type, one_to_many):
if targets is Nothing: if core_operation is Nothing:
pytest.skip(f"invalid parameter combination: {item_type=}, {one_to_many=}") pytest.skip(f"No operation defined for parameter combination: {item_type=}, {one_to_many=}")
output = client_pipeline(input_data_items, metadata) output = client_pipeline(input_data_items, metadata)
output = lmap(unpack, output) output = lmap(unpack, output)
assert output == targets assert output == targets
# @pytest.mark.parametrize("item_type", ["string"]) # @pytest.mark.parametrize("item_type", ["string"])
# @pytest.mark.parametrize("n_items", [1]) # @pytest.mark.parametrize("n_items", [1])
# def test_pipeline_is_lazy(input_data_items, metadata): # def test_pipeline_is_lazy(input_data_items, metadata):