(self, uow, recs)
| 748 | |
| 749 | @util.preload_module("sqlalchemy.orm.persistence") |
| 750 | def execute_aggregate(self, uow, recs): |
| 751 | persistence = util.preloaded.orm_persistence |
| 752 | cls_ = self.__class__ |
| 753 | mapper = self.mapper |
| 754 | our_recs = [ |
| 755 | r for r in recs if r.__class__ is cls_ and r.mapper is mapper |
| 756 | ] |
| 757 | recs.difference_update(our_recs) |
| 758 | persistence.save_obj( |
| 759 | mapper, [self.state] + [r.state for r in our_recs], uow |
| 760 | ) |
| 761 | |
| 762 | def __repr__(self): |
| 763 | return "%s(%s)" % ( |
nothing calls this directly
no test coverage detected