equal
deleted
inserted
replaced
438 """execute this step""" |
438 """execute this step""" |
439 todelete = frozenset(typed_eid(eid) for eid, in self.execute_child()) |
439 todelete = frozenset(typed_eid(eid) for eid, in self.execute_child()) |
440 session = self.plan.session |
440 session = self.plan.session |
441 delete = session.repo.glob_delete_entity |
441 delete = session.repo.glob_delete_entity |
442 # register pending eids first to avoid multiple deletion |
442 # register pending eids first to avoid multiple deletion |
443 pending = session.query_data('pendingeids', set(), setdefault=True) |
443 pending = session.transaction_data.setdefault('pendingeids', set()) |
444 actual = todelete - pending |
444 actual = todelete - pending |
445 pending |= actual |
445 pending |= actual |
446 for eid in actual: |
446 for eid in actual: |
447 delete(session, eid) |
447 delete(session, eid) |
448 |
448 |