diff --git a/python/pipeline/pipeline_server.py b/python/pipeline/pipeline_server.py index 0e802c7bc3db31238fa0d4ba8dda35e818131899..a6d4f9ed66fd8f563cb1526c136cba11b06fd6b3 100644 --- a/python/pipeline/pipeline_server.py +++ b/python/pipeline/pipeline_server.py @@ -181,7 +181,7 @@ class PipelineServer(object): def _start_local_rpc_service(self): # only brpc now if self._conf["dag"]["client_type"] != "brpc": - raise ValueError("Local service version must be brpc type now.") + _LOGGER.warning("Local service version must be brpc type now.") for op in self._used_op: if not isinstance(op, operator.RequestOp): op.launch_local_rpc_service()