diff options
author | Mike Bayer <mike_mp@zzzcomputing.com> | 2014-08-14 17:44:58 -0400 |
---|---|---|
committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2014-08-15 15:53:12 -0400 |
commit | 6bc676f56d57d5ea4dc298f63d0e3a77c0f4a4a1 (patch) | |
tree | 6cc346a727e50cfd8cbadb73df026fab533b8386 /lib/sqlalchemy/orm/unitofwork.py | |
parent | 191fd3e27e3ef90190f8315c33ba6eb97aeaf5d2 (diff) | |
download | sqlalchemy-6bc676f56d57d5ea4dc298f63d0e3a77c0f4a4a1.tar.gz |
dev
Diffstat (limited to 'lib/sqlalchemy/orm/unitofwork.py')
-rw-r--r-- | lib/sqlalchemy/orm/unitofwork.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/sqlalchemy/orm/unitofwork.py b/lib/sqlalchemy/orm/unitofwork.py index 8df24e95a..bc8a0f556 100644 --- a/lib/sqlalchemy/orm/unitofwork.py +++ b/lib/sqlalchemy/orm/unitofwork.py @@ -394,9 +394,9 @@ class UOWTransaction(object): if other: self.session._register_newly_persistent(other) - def bulk_save(self, objects): - for (base_mapper, in_session), states in itertools.groupby( - (attributes.instance_state(obj) for obj in objects), + def bulk_save(self, states): + for (base_mapper, in_session), states_ in itertools.groupby( + states, lambda state: ( state.mapper.base_mapper, @@ -404,12 +404,12 @@ class UOWTransaction(object): )): persistence.save_obj( - base_mapper, list(states), self, bookkeeping=in_session) + base_mapper, list(states_), self, bookkeeping=in_session) if in_session: self.states.update( (state, (False, False)) - for state in states + for state in states_ ) |