From 7a1b215d6978e502b7c02e0e512ba52972abaffe Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Wed, 1 Jun 2022 11:37:47 +0200 Subject: [PATCH] removed obsolete code --- pyinfra/server/server.py | 29 +---------------------------- 1 file changed, 1 insertion(+), 28 deletions(-) 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)}