diff --git a/python/examples/senta/senta_web_service.py b/python/examples/senta/senta_web_service.py index 0c0205e73cdd26231a94b2f0c9c41da84aaca961..5d20020c46d3b5ed23914cb9813ac889e232a2b3 100644 --- a/python/examples/senta/senta_web_service.py +++ b/python/examples/senta/senta_web_service.py @@ -51,13 +51,11 @@ class SentaService(WebService): def init_lac_service(self): ps = Process(target=self.start_lac_service()) ps.start() - #self.init_lac_client() + self.init_lac_client() def lac_predict(self, feed_data): - self.init_lac_client() lac_result = self.lac_client.predict( feed={"words": feed_data}, fetch=["crf_decode"]) - self.lac_client.release() return lac_result def init_lac_client(self): diff --git a/python/paddle_serving_server/web_service.py b/python/paddle_serving_server/web_service.py index 7e69b241f50255aa69d34c1405b72eacb675be04..cfd75b88ad7ef395a97bc7126404581ac089db5b 100755 --- a/python/paddle_serving_server/web_service.py +++ b/python/paddle_serving_server/web_service.py @@ -101,7 +101,6 @@ class WebService(object): p_rpc = Process(target=self._launch_rpc_service) p_rpc.start() - def run_flask(self): app_instance = Flask(__name__) @app_instance.before_first_request @@ -114,10 +113,16 @@ class WebService(object): def run(): return self.get_prediction(request) + self.app_instance = app_instance + + def run_flask(self): app_instance.run(host="0.0.0.0", port=self.port, threaded=False, - processes=4) + processes=1) + + def get_app_instance(self): + return self.app_instance def preprocess(self, feed=[], fetch=[]): return feed, fetch diff --git a/python/paddle_serving_server_gpu/web_service.py b/python/paddle_serving_server_gpu/web_service.py index 2ec996b1db89bdff3c4550caa566bec5af2d9506..806ea85ba52fc3e19f8c2893d98598db0f944934 100644 --- a/python/paddle_serving_server_gpu/web_service.py +++ b/python/paddle_serving_server_gpu/web_service.py @@ -151,7 +151,6 @@ class WebService(object): for p in server_pros: p.start() - def run_flask(self): app_instance = Flask(__name__) @app_instance.before_first_request @@ -164,10 +163,16 @@ class WebService(object): def run(): return self.get_prediction(request) + self.app_instance = app_instance + + def run_flask(self): app_instance.run(host="0.0.0.0", port=self.port, threaded=False, - processes=4) + processes=1) + + def get_app_instance(self): + return app_instance def preprocess(self, feed=[], fetch=[]): return feed, fetch