removed obsolete code
This commit is contained in:
parent
01ce914417
commit
7a1b215d69
@ -1,5 +1,5 @@
|
||||
from functools import singledispatch
|
||||
from typing import Dict, Callable
|
||||
from typing import Dict
|
||||
|
||||
from flask import Flask, jsonify, request
|
||||
from funcy import merge
|
||||
@ -16,33 +16,6 @@ def set_up_processing_server(server_stream_function, buffer_size):
|
||||
return __set_up_processing_server(operation2function)
|
||||
|
||||
|
||||
# def __set_up_processing_server(queued_stream_function: QueuedStreamFunction):
|
||||
# app = Flask(__name__)
|
||||
# processor = LazyRestProcessor(queued_stream_function, submit_suffix="submit", pickup_suffix="pickup")
|
||||
#
|
||||
# @app.route("/ready", methods=["GET"])
|
||||
# def ready():
|
||||
# resp = jsonify("OK")
|
||||
# resp.status_code = 200
|
||||
# return resp
|
||||
#
|
||||
# @app.route("/health", methods=["GET"])
|
||||
# def healthy():
|
||||
# resp = jsonify("OK")
|
||||
# resp.status_code = 200
|
||||
# return resp
|
||||
#
|
||||
# @app.route("/submit", methods=["POST", "PATCH"])
|
||||
# def submit():
|
||||
# return processor.push(request)
|
||||
#
|
||||
# @app.route("/pickup", methods=["GET"])
|
||||
# def pickup():
|
||||
# return processor.pop()
|
||||
#
|
||||
# return app
|
||||
|
||||
|
||||
def build_endpoint_suffixes(op: str):
|
||||
return {"submit_suffix": submit_suffix(op), "pickup_suffix": pickup_suffix(op)}
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user