提交 6826ee44 编写于 作者: B barrierye

update code

上级 d9fd4f24
...@@ -181,7 +181,7 @@ class PipelineServer(object): ...@@ -181,7 +181,7 @@ class PipelineServer(object):
def _start_local_rpc_service(self): def _start_local_rpc_service(self):
# only brpc now # only brpc now
if self._conf["dag"]["client_type"] != "brpc": 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: for op in self._used_op:
if not isinstance(op, operator.RequestOp): if not isinstance(op, operator.RequestOp):
op.launch_local_rpc_service() op.launch_local_rpc_service()
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册