fixup! subscription: return parent node to oper_state callback

Author: avazquezrd

sysrepo/session.py

@@ -372,15 +372,15 @@ def subscribe_module_change(
 
         self.subscriptions.append(sub)
 
-    OperDataCallbackType = Callable[[str, Optional[libyang.DNode], Any], Optional[Dict]]
+    OperDataCallbackType = Callable[[str, Optional[str], Any], Optional[Dict]]
     """
     Callback to be called when the operational data are requested.
 
     :arg xpath:
         The XPath requested by a client. Can be None if the client requested for all the
         module operational data.
-    :arg parent:
-        Pointer to an existing parent of the requested nodes. It is None for top-level
+    :arg parent_xpath:
+        XPath to an existing parent of the requested nodes. It is None for top-level
         nodes. Caller is supposed to append the requested nodes to this data subtree
         and return either the original parent or a top-level node.
     :arg private_data:

sysrepo/subscription.py

@@ -367,17 +367,17 @@ def oper_data_callback(session, sub_id, module, xpath, req_xpath, req_id, parent
         else:
             extra_info = {}
 
-        parent_node = None
+        parent_xpath = None
         if parent[0]:
             with session.get_ly_ctx() as ly_ctx:
-                parent_node = DNode.new(ly_ctx, parent[0])
+                parent_xpath = DNode.new(ly_ctx, parent[0]).path()
 
         if is_async_func(callback):
             task_id = req_id
 
             if task_id not in subscription.tasks:
                 task = subscription.loop.create_task(
-                    callback(req_xpath, parent_node, private_data, **extra_info)
+                    callback(req_xpath, parent_xpath, private_data, **extra_info)
                 )
                 task.add_done_callback(
                     functools.partial(subscription.task_done, task_id, "oper")
@@ -394,7 +394,7 @@ def oper_data_callback(session, sub_id, module, xpath, req_xpath, req_id, parent
             oper_data = task.result()
 
         else:
-            oper_data = callback(req_xpath, parent_node, private_data, **extra_info)
+            oper_data = callback(req_xpath, parent_xpath, private_data, **extra_info)
 
         if isinstance(oper_data, dict):
             # convert oper_data to a libyang.DNode object