'Update the max stream_id
Args:
txn: The database cursor
next_id(int): The the revision to advance to.'

def _update_max_stream_id(self, txn, next_id):

    update_max_id_sql = 'UPDATE    account_data_max_stream_id    SET    stream_id    =    ?    WHERE    stream_id    <    ?'
    txn.execute(update_max_id_sql, (next_id, next_id))
