diff --git a/pyinfra/server/server.py b/pyinfra/server/server.py index 4149c21..21781e2 100644 --- a/pyinfra/server/server.py +++ b/pyinfra/server/server.py @@ -12,8 +12,7 @@ from pyinfra.server.stream.rest import LazyRestProcessor def set_up_processing_server(server_stream_function, buffer_size): flat_stream_buffer = FlatStreamBuffer(server_stream_function, buffer_size=buffer_size) queued_stream_function = QueuedStreamFunction(flat_stream_buffer) - operation2function = {None: queued_stream_function} - return __set_up_processing_server(operation2function) + return __set_up_processing_server(queued_stream_function) def build_endpoint_suffixes(op: str): @@ -21,7 +20,7 @@ def build_endpoint_suffixes(op: str): def submit_suffix(op: str): - return "submit" if not op else f"{op}_submit" + return "submit" if not op else op def pickup_suffix(op: str):