Skip to content

Commit fd45a8b

Browse files
committed
Fix compatibility with SQLAlchemy 1.1.
1 parent 1a7ed7b commit fd45a8b

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

database.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,10 @@ def log_transaction(session, flush_context):
2525
#print >> sys.stderr, "> Dirty objects map: %s" % ([session.is_modified(x) for x in session.dirty],)
2626
#print >> sys.stderr, "> Flush will change anything? %s" % (flush_changes_anything(session),)
2727
if flush_changes_anything(session):
28-
for trans in session.transaction._iterate_parents():
28+
trans = session.transaction
29+
while trans is not None:
2930
transactions_with_flushes.add(trans)
31+
trans = trans.parent
3032

3133
def session_has_pending_commit(session):
3234
session.flush()

0 commit comments

Comments
 (0)