src/dirbs/listgen/generator.py
def _populate_new_exceptions_lists(self, executor):
        """Top-level job function to create the new per-MNO pairings lists."""
        with create_db_connection(self._config.db_config) as conn, CodeProfiler() as cp:
            # Commit so that queued jobs can see results
            with conn:
                # First generate the table of IMEI/IMSIs to pair, along with home network.
                self._run_intermediate_table_job(conn,
                                                 self._populate_new_pairings_imei_imsi_table,
                                                 description='IMEI/IMSI pairings')

            # Setup jobs to create per-MNO partitions that allocate notifications from the triplets to notify table
            per_mno_jobs = {}
            for op in self._operators:
                self._queue_intermediate_table_job(executor,
                                                   per_mno_jobs,
                                                   partial(self._populate_new_exceptions_list, op.id),
                                                   'per-MNO exceptions for {0}'.format(op.id))
            self._wait_for_futures(per_mno_jobs)

            # ANALYZE parent table, which analyzes children as well
            with conn.cursor() as cursor:
                self._analyze_helper(cursor, self._exceptions_lists_new_tblname)

        return -1, cp.duration
Top-level job function to create the new per-MNO pairings lists.
Top-level job function to create the new per-MNO pairings lists.
Top - level job function to create the new per - MNO pairings lists .
def _populate_new_exceptions_lists(self, executor):
        with create_db_connection(self._config.db_config) as conn, CodeProfiler() as cp:
            with conn:
                self._run_intermediate_table_job(conn,
                                                 self._populate_new_pairings_imei_imsi_table,
                                                 description='IMEI/IMSI pairings')
            per_mno_jobs = {}
            for op in self._operators:
                self._queue_intermediate_table_job(executor,
                                                   per_mno_jobs,
                                                   partial(self._populate_new_exceptions_list, op.id),
                                                   'per-MNO exceptions for {0}'.format(op.id))
            self._wait_for_futures(per_mno_jobs)
            with conn.cursor() as cursor:
                self._analyze_helper(cursor, self._exceptions_lists_new_tblname)
        return -1, cp.duration
def _populate_new_exceptions_lists ( self , executor ) : with create_db_connection ( self . _config . db_config ) as conn , CodeProfiler ( ) as cp : with conn : self . _run_intermediate_table_job ( conn , self . _populate_new_pairings_imei_imsi_table , description = 'IMEI/IMSI pairings' ) per_mno_jobs = { } for op in self . _operators : self . _queue_intermediate_table_job ( executor , per_mno_jobs , partial ( self . _populate_new_exceptions_list , op . id ) , 'per-MNO exceptions for {0}' . format ( op . id ) ) self . _wait_for_futures ( per_mno_jobs ) with conn . cursor ( ) as cursor : self . _analyze_helper ( cursor , self . _exceptions_lists_new_tblname ) return - 1 , cp . duration
Top-level job function to create the new per-MNO pairings lists.
Top - level job function to create the new per - MNO pairings lists .
"""Top-level job function to create the new per-MNO pairings lists.""" # Commit so that queued jobs can see results # First generate the table of IMEI/IMSIs to pair, along with home network. # Setup jobs to create per-MNO partitions that allocate notifications from the triplets to notify table # ANALYZE parent table, which analyzes children as well
self
executor