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

renaming

Browse Source
This commit is contained in:
Matthias Bisping 2022-05-17 12:10:24 +02:00
parent 5590669939
commit fb325ce43d
2 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
pyinfra/server/dispatcher/dispatchers/forwarding.py → pyinfra/server/dispatcher/dispatchers/queue.py
View File

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

@ -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=}")