refactoring: rename

pyinfra/server/rest.py

@@ -2,7 +2,7 @@ from typing import Iterable
 
 from funcy import rcompose
 
-from pyinfra.server.dispatcher.senders.rest import RestDispatcher
+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
 from pyinfra.server.packer.packers.rest import RestPacker

test/fixtures/input.py

@@ -45,12 +45,12 @@ def endpoint(url, analysis_type):
     }[analysis_type]
 
 
-@pytest.fixture(params=[0, 1, 5, 10])
+@pytest.fixture(params=[0, 2, 5])
 def n_items(request):
     return request.param
 
 
-@pytest.fixture(params=[0, 5, 100])
+@pytest.fixture(params=[0, 100])
 def n_pages(request):
     return request.param
 
@@ -60,7 +60,7 @@ def analysis_type(request):
     return request.param
 
 
-@pytest.fixture(params=[1, 5, 90])
+@pytest.fixture(params=[1, 5])
 def buffer_size(request):
     return request.param
 

test/unit_tests/pipeline_test.py

@@ -1,7 +1,7 @@
 import pytest
 from funcy import rcompose, lmap
 
-from pyinfra.server.dispatcher.senders.rest import RestDispatcher
+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
 from pyinfra.server.packer.packers.rest import RestPacker

test/unit_tests/rest/receiver_test.py

@@ -1,7 +1,7 @@
 import pytest
 
 from pyinfra.server.receiver.receivers.rest import RestReceiver
-from pyinfra.server.dispatcher.senders.rest import RestDispatcher
+from pyinfra.server.dispatcher.dispatchers.rest import RestDispatcher
 
 
 @pytest.mark.parametrize("batched", [True, False])

test/unit_tests/rest/sender_test.py

@@ -1,6 +1,6 @@
 import pytest
 
-from pyinfra.server.dispatcher.senders.rest import RestDispatcher
+from pyinfra.server.dispatcher.dispatchers.rest import RestDispatcher
 
 
 @pytest.mark.parametrize("batched", [True, False])