(self, uow, recs)
| 712 | self.state = state |
| 713 | |
| 714 | def execute_aggregate(self, uow, recs): |
| 715 | cls_ = self.__class__ |
| 716 | dependency_processor = self.dependency_processor |
| 717 | isdelete = self.isdelete |
| 718 | our_recs = [ |
| 719 | r |
| 720 | for r in recs |
| 721 | if r.__class__ is cls_ |
| 722 | and r.dependency_processor is dependency_processor |
| 723 | and r.isdelete is isdelete |
| 724 | ] |
| 725 | recs.difference_update(our_recs) |
| 726 | states = [self.state] + [r.state for r in our_recs] |
| 727 | if isdelete: |
| 728 | dependency_processor.process_deletes(uow, states) |
| 729 | else: |
| 730 | dependency_processor.process_saves(uow, states) |
| 731 | |
| 732 | def __repr__(self): |
| 733 | return "%s(%s, %s, delete=%s)" % ( |
nothing calls this directly
no test coverage detected