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