session = sessionmaker(engine)(twophase=True)
session.add(obj1)
session.prepare()
for k, v in s.transaction._connections.items():
    if isinstance(k, Connection):
        return v[1].xid
Как обрабатывать двухэтапную фиксацию с помощью SQLAlchemy