src/dirbs/listgen/generator.py
def _create_intermediate_delta_tables(self):
        """Creates tables containing the deltas between the old and new lists."""
        with self._conn as conn:
            self._run_intermediate_table_job(conn, self._create_intermediate_delta_tables_structure)

        with self._conn as conn, futures.ThreadPoolExecutor(max_workers=self._nworkers) as executor:
            futures_to_cb = {}
            self._queue_intermediate_table_job(executor,
                                               futures_to_cb,
                                               self._populate_delta_blacklist,
                                               'delta blacklist')
            for op in self._operators:
                self._queue_intermediate_table_job(executor,
                                                   futures_to_cb,
                                                   partial(self._populate_delta_notifications_list, op.id),
                                                   'delta notifications for {0}'.format(op.id))
                self._queue_intermediate_table_job(executor,
                                                   futures_to_cb,
                                                   partial(self._populate_delta_exceptions_list, op.id),
                                                   'delta exceptions for {0}'.format(op.id))
            self._wait_for_futures(futures_to_cb)

            # ANALYZE parent tables, which analyzes children as well
            with conn.cursor() as cursor:
                self._analyze_helper(cursor, self._notifications_lists_delta_tblname)
                self._analyze_helper(cursor, self._exceptions_lists_delta_tblname)
Creates tables containing the deltas between the old and new lists.
Creates tables containing the deltas between the old and new lists.
Creates tables containing the deltas between the old and new lists .
def _create_intermediate_delta_tables(self):
        with self._conn as conn:
            self._run_intermediate_table_job(conn, self._create_intermediate_delta_tables_structure)
        with self._conn as conn, futures.ThreadPoolExecutor(max_workers=self._nworkers) as executor:
            futures_to_cb = {}
            self._queue_intermediate_table_job(executor,
                                               futures_to_cb,
                                               self._populate_delta_blacklist,
                                               'delta blacklist')
            for op in self._operators:
                self._queue_intermediate_table_job(executor,
                                                   futures_to_cb,
                                                   partial(self._populate_delta_notifications_list, op.id),
                                                   'delta notifications for {0}'.format(op.id))
                self._queue_intermediate_table_job(executor,
                                                   futures_to_cb,
                                                   partial(self._populate_delta_exceptions_list, op.id),
                                                   'delta exceptions for {0}'.format(op.id))
            self._wait_for_futures(futures_to_cb)
            with conn.cursor() as cursor:
                self._analyze_helper(cursor, self._notifications_lists_delta_tblname)
                self._analyze_helper(cursor, self._exceptions_lists_delta_tblname)
def _create_intermediate_delta_tables ( self ) : with self . _conn as conn : self . _run_intermediate_table_job ( conn , self . _create_intermediate_delta_tables_structure ) with self . _conn as conn , futures . ThreadPoolExecutor ( max_workers = self . _nworkers ) as executor : futures_to_cb = { } self . _queue_intermediate_table_job ( executor , futures_to_cb , self . _populate_delta_blacklist , 'delta blacklist' ) for op in self . _operators : self . _queue_intermediate_table_job ( executor , futures_to_cb , partial ( self . _populate_delta_notifications_list , op . id ) , 'delta notifications for {0}' . format ( op . id ) ) self . _queue_intermediate_table_job ( executor , futures_to_cb , partial ( self . _populate_delta_exceptions_list , op . id ) , 'delta exceptions for {0}' . format ( op . id ) ) self . _wait_for_futures ( futures_to_cb ) with conn . cursor ( ) as cursor : self . _analyze_helper ( cursor , self . _notifications_lists_delta_tblname ) self . _analyze_helper ( cursor , self . _exceptions_lists_delta_tblname )
Creates tables containing the deltas between the old and new lists.
Creates tables containing the deltas between the old and new lists .
"""Creates tables containing the deltas between the old and new lists.""" # ANALYZE parent tables, which analyzes children as well
self