submit endpoint is now 'submit' or 'operation'
This commit is contained in:
parent
7a1b215d69
commit
ecff50ae7c
@ -12,8 +12,7 @@ from pyinfra.server.stream.rest import LazyRestProcessor
|
|||||||
def set_up_processing_server(server_stream_function, buffer_size):
|
def set_up_processing_server(server_stream_function, buffer_size):
|
||||||
flat_stream_buffer = FlatStreamBuffer(server_stream_function, buffer_size=buffer_size)
|
flat_stream_buffer = FlatStreamBuffer(server_stream_function, buffer_size=buffer_size)
|
||||||
queued_stream_function = QueuedStreamFunction(flat_stream_buffer)
|
queued_stream_function = QueuedStreamFunction(flat_stream_buffer)
|
||||||
operation2function = {None: queued_stream_function}
|
return __set_up_processing_server(queued_stream_function)
|
||||||
return __set_up_processing_server(operation2function)
|
|
||||||
|
|
||||||
|
|
||||||
def build_endpoint_suffixes(op: str):
|
def build_endpoint_suffixes(op: str):
|
||||||
@ -21,7 +20,7 @@ def build_endpoint_suffixes(op: str):
|
|||||||
|
|
||||||
|
|
||||||
def submit_suffix(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):
|
def pickup_suffix(op: str):
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user