l.s.d.m.PouringLoop : class documentation

Part of lp.services.database.multitablecopy View In Hierarchy

Loop body to pour data from holding tables back into source tables.

Used by MultiTableCopy internally to tell DBLoopTuner what to do.

Method __init__ Undocumented
Method isDone See ITunableLoop.
Method __call__ See ITunableLoop.
Method prepareBatch If batch_pouring_callback is defined, call it.
Method _commit Commit ongoing transaction, start a new one.
def __init__(self, from_table, to_table, transaction_manager, logger, batch_pouring_callback=None):
Undocumented
def isDone(self):
See ITunableLoop.
def __call__(self, batch_size):
See ITunableLoop.

Loop body: pour rows with ids up to "next" over to to_table.

def _commit(self):
Commit ongoing transaction, start a new one.
def prepareBatch(self, from_table, to_table, batch_size, begin_id, end_id):
If batch_pouring_callback is defined, call it.
API Documentation for Launchpad, generated by pydoctor at 2022-06-16 00:00:12.