From 5430cf17a6c8e9cb01ccda57c3f14b671059e0e8 Mon Sep 17 00:00:00 2001 From: barrierye Date: Thu, 2 Jul 2020 12:43:10 +0800 Subject: [PATCH] add info log --- python/pipeline/pipeline_server.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/python/pipeline/pipeline_server.py b/python/pipeline/pipeline_server.py index dabb1bcd..9c891afe 100644 --- a/python/pipeline/pipeline_server.py +++ b/python/pipeline/pipeline_server.py @@ -235,6 +235,10 @@ class PipelineServer(object): return use_ops, succ_ops_of_use_op use_ops, out_degree_ops = get_use_ops(response_op) + _LOGGER.info("================= use op ==================") + for op in use_ops: + _LOGGER.debug(op.name) + _LOGGER.info("===========================================") if len(use_ops) <= 1: raise Exception( "Besides RequestOp and ResponseOp, there should be at least one Op in DAG." @@ -384,7 +388,7 @@ class PipelineServer(object): def prepare_server(self, yml_file): with open(yml_file) as f: - yml_config = yaml.load(f.read(), Loader=yaml.FullLoader) + yml_config = yaml.load(f.read()) self._port = yml_config.get('port', 8080) if not self._port_is_available(self._port): raise SystemExit("Prot {} is already used".format(self._port)) -- GitLab