diff options
| author | LV-426 <lv-426@taproot.org.il> | 2015-04-29 17:45:02 +0300 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2015-04-29 17:46:39 +0300 |
| commit | 3c63ec6518f5f43ca907a56896445383469862f9 (patch) | |
| tree | 444091016773349a7ad34c365527ece7aa17da2a /src | |
| parent | e978b71eb92ce375aacba4699e558c991f2cea56 (diff) | |
db_op: composed op: post_op_exec_hook() - provide room for post-sub-op logic
Diffstat (limited to 'src')
| -rw-r--r-- | src/server/db_controller.py | 2 | ||||
| -rw-r--r-- | src/server/db_op.py | 4 |
2 files changed, 5 insertions, 1 deletions
diff --git a/src/server/db_controller.py b/src/server/db_controller.py index 5d3618ff..33b595de 100644 --- a/src/server/db_controller.py +++ b/src/server/db_controller.py @@ -32,7 +32,7 @@ class DB_Controller: for sub_op in op.iter__sub_op(): sub_op_ret = self.exec_op(sub_op) # recursive call - op.inter_op_exec_hook(sub_op_ret) + op.post_sub_op_exec_hook(sub_op, sub_op_ret) op_ret = op.process_result_set() return op_ret diff --git a/src/server/db_op.py b/src/server/db_op.py index 2fc7cefc..f28dc320 100644 --- a/src/server/db_op.py +++ b/src/server/db_op.py @@ -177,8 +177,12 @@ class DB_composed_op(DB_op): for s_op in self.sub_op_set: yield s_op + def post_sub_op_exec_hook(self, prv_sub_op, prv_sub_op_ret): """ + Called after each successful sub-op execution. Throwing an exception here + will prevent the execution of the subsequent sub_op's. """ + pass def process_result_set(self): ret = [] |
