summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-01-20 13:22:31 +0200
committerLV-426 <lv-426@taproot.org.il>2015-01-20 14:02:10 +0200
commit60d971489007d2a5cd7f97dc82ec37a9eda22e94 (patch)
tree8ba5027587cdcc484a347a3f697ee573f5749659 /src
parent88ff9c171992dea974909b5aadf6405eda0aaacf (diff)
rz_api#rz_clone(): adapt to db_controller yield return style
Diffstat (limited to 'src')
-rw-r--r--src/server/rz_api.py11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/server/rz_api.py b/src/server/rz_api.py
index 98d46136..f38c4279 100644
--- a/src/server/rz_api.py
+++ b/src/server/rz_api.py
@@ -114,10 +114,15 @@ def load_link_set_by_link_ptr_set():
def rz_clone():
- def on_success(topo_diff):
+ def on_success(op_op_ret_pair):
# serialize Topo_Diff before including in response
- topo_diff_json = topo_diff.to_json_dict()
- return common_resp_handle(topo_diff_json)
+ for _, op_ret in op_op_ret_pair: # discard op
+
+ assert isinstance(op_ret, Topo_Diff), 'rz_clone: op_ret != Topo_Diff'
+
+ topo_diff = op_ret
+ topo_diff_json = topo_diff.to_json_dict()
+ return common_resp_handle(topo_diff_json)
op = DBO_rz_clone()
return __common_exec(op, on_success=on_success)