'Add a database connection to the meta-transaction if active.'

def add_engine(self, engine):

    if (not self.transaction_begun):
        return
    if (engine not in self.transacting_engines):
        engine.begin()
        self.transacting_engines.add(engine)
