equal
deleted
inserted
replaced
505 """step consisting in deleting entities""" |
505 """step consisting in deleting entities""" |
506 |
506 |
507 def execute(self): |
507 def execute(self): |
508 """execute this step""" |
508 """execute this step""" |
509 results = self.execute_child() |
509 results = self.execute_child() |
510 todelete = frozenset(typed_eid(eid) for eid, in self.execute_child()) |
510 todelete = frozenset(typed_eid(eid) for eid, in results) |
511 session = self.plan.session |
511 session = self.plan.session |
512 delete = session.repo.glob_delete_entity |
512 delete = session.repo.glob_delete_entity |
513 # register pending eids first to avoid multiple deletion |
513 # register pending eids first to avoid multiple deletion |
514 pending = session.transaction_data.setdefault('pendingeids', set()) |
514 pending = session.transaction_data.setdefault('pendingeids', set()) |
515 actual = todelete - pending |
515 actual = todelete - pending |