grpc: fixed issue with not catching error in delete_node from broadcast changes
This commit is contained in:
parent
5eae67aac5
commit
c8daeb02d8
1 changed files with 1 additions and 3 deletions
|
@ -778,13 +778,11 @@ class CoreGrpcServer(core_pb2_grpc.CoreApiServicer):
|
||||||
logging.debug("delete node: %s", request)
|
logging.debug("delete node: %s", request)
|
||||||
session = self.get_session(request.session_id, context)
|
session = self.get_session(request.session_id, context)
|
||||||
result = False
|
result = False
|
||||||
try:
|
if request.node_id in session.nodes:
|
||||||
node = self.get_node(session, request.node_id, context, NodeBase)
|
node = self.get_node(session, request.node_id, context, NodeBase)
|
||||||
result = session.delete_node(node.id)
|
result = session.delete_node(node.id)
|
||||||
source = request.source if request.source else None
|
source = request.source if request.source else None
|
||||||
session.broadcast_node(node, MessageFlags.DELETE, source)
|
session.broadcast_node(node, MessageFlags.DELETE, source)
|
||||||
except grpc.RpcError:
|
|
||||||
pass
|
|
||||||
return core_pb2.DeleteNodeResponse(result=result)
|
return core_pb2.DeleteNodeResponse(result=result)
|
||||||
|
|
||||||
def NodeCommand(
|
def NodeCommand(
|
||||||
|
|
Loading…
Add table
Reference in a new issue