src/dirbs/importer/base_delta_importer.py
def _vacuum_table_helper(self, tbl_name):
        """Function to DRY out code for VACUUM ANALYZE'ing a table."""
        # Use new autocommit connction to do VACUUM ANALYZE since it can't be done in a transaction
        self._logger.info('Running VACUUM ANALYZE on {0}...'.format(tbl_name))
        with utils.create_db_connection(self._db_config, autocommit=True) as conn, conn.cursor() as cursor:
            cursor.execute(sql.SQL('VACUUM ANALYZE {0}').format(sql.Identifier(tbl_name)))
        self._logger.info('Finished running VACUUM ANALYZE on {0}'.format(tbl_name))
Function to DRY out code for VACUUM ANALYZE'ing a table.
Function to DRY out code for VACUUM ANALYZE'ing a table.
Function to DRY out code for VACUUM ANALYZE ' ing a table .
def _vacuum_table_helper(self, tbl_name):
        self._logger.info('Running VACUUM ANALYZE on {0}...'.format(tbl_name))
        with utils.create_db_connection(self._db_config, autocommit=True) as conn, conn.cursor() as cursor:
            cursor.execute(sql.SQL('VACUUM ANALYZE {0}').format(sql.Identifier(tbl_name)))
        self._logger.info('Finished running VACUUM ANALYZE on {0}'.format(tbl_name))
def _vacuum_table_helper ( self , tbl_name ) : self . _logger . info ( 'Running VACUUM ANALYZE on {0}...' . format ( tbl_name ) ) with utils . create_db_connection ( self . _db_config , autocommit = True ) as conn , conn . cursor ( ) as cursor : cursor . execute ( sql . SQL ( 'VACUUM ANALYZE {0}' ) . format ( sql . Identifier ( tbl_name ) ) ) self . _logger . info ( 'Finished running VACUUM ANALYZE on {0}' . format ( tbl_name ) )
Function to DRY out code for VACUUM ANALYZE'ing a table.
Function to DRY out code for VACUUM ANALYZE ' ing a table .
"""Function to DRY out code for VACUUM ANALYZE'ing a table.""" # Use new autocommit connction to do VACUUM ANALYZE since it can't be done in a transaction
self
tbl_name