From 9871fa3e8393b0d05bd84712c485721ad5882146 Mon Sep 17 00:00:00 2001 From: LV-426 Date: Mon, 23 Mar 2015 16:36:21 +0200 Subject: RZ_Kernel: apply QT_Node_Filter__Doc_ID_Label transformation based on doc_id context --- src/server/rz_kernel.py | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'src/server/rz_kernel.py') diff --git a/src/server/rz_kernel.py b/src/server/rz_kernel.py index d80fe99d..424353ed 100644 --- a/src/server/rz_kernel.py +++ b/src/server/rz_kernel.py @@ -9,6 +9,7 @@ import db_controller from db_op import DBO_diff_commit__attr, DBO_block_chain__commit from db_op import DBO_diff_commit__topo from model.graph import Topo_Diff +from neo4j_cypher import QT_Node_Filter__Doc_ID_Label log = logging.getLogger('rhizi') @@ -35,7 +36,12 @@ class RZ_Kernel(object): @return: a tuple containing the input diff and the result of it's commit """ + rzdoc_id = ctx.get('rzdoc_id') + assert rzdoc_id, 'diff_commit__topo: missing doc id' + op = DBO_diff_commit__topo(topo_diff) + op = QT_Node_Filter__Doc_ID_Label(rzdoc_id)(op) + try: op_ret = self.db_ctl.exec_op(op) @@ -56,7 +62,12 @@ class RZ_Kernel(object): @return: a tuple containing the input diff and the result of it's commit """ + rzdoc_id = ctx.get('rzdoc_id') + assert rzdoc_id, 'diff_commit__topo: missing doc id' + op = DBO_diff_commit__attr(attr_diff) + op = QT_Node_Filter__Doc_ID_Label(rzdoc_id)(op) + try: op_ret = self.db_ctl.exec_op(op) -- cgit v1.3.1