diff --git a/pyinfra/server/server.py b/pyinfra/server/server.py index b9b0657..4149c21 100644 --- a/pyinfra/server/server.py +++ b/pyinfra/server/server.py @@ -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)}