From fb325ce43d61864544ae7fd1940c20adc11b3071 Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Tue, 17 May 2022 12:10:24 +0200 Subject: [PATCH] renaming --- .../dispatcher/dispatchers/{forwarding.py => queue.py} | 0 test/unit_tests/server/pipeline_test.py | 10 ++-------- 2 files changed, 2 insertions(+), 8 deletions(-) rename pyinfra/server/dispatcher/dispatchers/{forwarding.py => queue.py} (100%) diff --git a/pyinfra/server/dispatcher/dispatchers/forwarding.py b/pyinfra/server/dispatcher/dispatchers/queue.py similarity index 100% rename from pyinfra/server/dispatcher/dispatchers/forwarding.py rename to pyinfra/server/dispatcher/dispatchers/queue.py diff --git a/test/unit_tests/server/pipeline_test.py b/test/unit_tests/server/pipeline_test.py index ec48807..8d7fcd0 100644 --- a/test/unit_tests/server/pipeline_test.py +++ b/test/unit_tests/server/pipeline_test.py @@ -4,7 +4,7 @@ from funcy import rcompose, compose from pyinfra.server.buffering.stream import FlatStreamBuffer from pyinfra.server.client_pipeline import ClientPipeline from pyinfra.server.dispatcher.dispatcher import Nothing -from pyinfra.server.dispatcher.dispatchers.forwarding import QueuedStreamFunctionDispatcher +from pyinfra.server.dispatcher.dispatchers.queue import QueuedStreamFunctionDispatcher from pyinfra.server.dispatcher.dispatchers.rest import RestDispatcher from pyinfra.server.interpreter.interpreters.identity import IdentityInterpreter from pyinfra.server.interpreter.interpreters.rest_callback import RestPickupStreamer @@ -28,13 +28,7 @@ def test_mock_pipeline(): assert list(pipeline(data)) == list(rcompose(f, g, h, u)(data)) -@pytest.mark.parametrize( - "client_pipeline_type", - [ - "rest", - "basic", - ], -) +@pytest.mark.parametrize("client_pipeline_type", ["rest", "basic"]) def test_pipeline(core_operation, client_pipeline, input_data_items, metadata, targets, item_type, one_to_many): if core_operation is Nothing: pytest.skip(f"No operation defined for parameter combination: {item_type=}, {one_to_many=}")