diff options
| -rw-r--r-- | lib/sqlalchemy/orm/persistence.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/sqlalchemy/orm/persistence.py b/lib/sqlalchemy/orm/persistence.py index 746395919..31c9891b8 100644 --- a/lib/sqlalchemy/orm/persistence.py +++ b/lib/sqlalchemy/orm/persistence.py @@ -608,9 +608,10 @@ def _emit_post_update_statements(base_mapper, uowtransaction, for key, grouper in groupby( update, lambda rec: (rec[4], rec[2].keys()) ): + connection = key[0] multiparams = [params for state, state_dict, params, mapper, conn in grouper] - cached_connections[conn].\ + cached_connections[connection].\ execute(statement, multiparams) |