equal
deleted
inserted
replaced
52 def commit_event(self): |
52 def commit_event(self): |
53 """the observed connections pool has been rollbacked, |
53 """the observed connections pool has been rollbacked, |
54 remove inserted eid from repository type/source cache |
54 remove inserted eid from repository type/source cache |
55 """ |
55 """ |
56 try: |
56 try: |
57 self.repo.clear_caches(self.session.transaction_data['pendingeids']) |
57 self.session.repo.clear_caches( |
|
58 self.session.transaction_data['pendingeids']) |
58 except KeyError: |
59 except KeyError: |
59 pass |
60 pass |
60 |
61 |
61 def rollback_event(self): |
62 def rollback_event(self): |
62 """the observed connections pool has been rollbacked, |
63 """the observed connections pool has been rollbacked, |
63 remove inserted eid from repository type/source cache |
64 remove inserted eid from repository type/source cache |
64 """ |
65 """ |
65 try: |
66 try: |
66 self.repo.clear_caches(self.session.transaction_data['neweids']) |
67 self.session.repo.clear_caches( |
|
68 self.session.transaction_data['neweids']) |
67 except KeyError: |
69 except KeyError: |
68 pass |
70 pass |
69 |
71 |
70 |
72 |
71 class FTIndexEntityOp(hook.LateOperation): |
73 class FTIndexEntityOp(hook.LateOperation): |