diff options
| author | LV-426 <lv-426@taproot.org.il> | 2015-01-20 13:22:31 +0200 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2015-01-20 14:02:10 +0200 |
| commit | 60d971489007d2a5cd7f97dc82ec37a9eda22e94 (patch) | |
| tree | 8ba5027587cdcc484a347a3f697ee573f5749659 /src | |
| parent | 88ff9c171992dea974909b5aadf6405eda0aaacf (diff) | |
rz_api#rz_clone(): adapt to db_controller yield return style
Diffstat (limited to 'src')
| -rw-r--r-- | src/server/rz_api.py | 11 |
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) |
