src/dirbs/importer/operator_data_importer.py
def _process_network_imeis_result(self, state, future):
        """Process a network_imeis future, mutating the passed state."""
        future.result()  # will throw exception if this one was thrown in thread
        state['num_processed'] += 1
        self._logger.info('Updated network_imeis table with unseen imeis [{0:d} of {1:d} partitions]'
                          .format(state['num_processed'], state['num_jobs']))
Process a network_imeis future, mutating the passed state.
Process a network_imeis future, mutating the passed state.
Process a network_imeis future mutating the passed state .
def _process_network_imeis_result(self, state, future):
        future.result()  
        state['num_processed'] += 1
        self._logger.info('Updated network_imeis table with unseen imeis [{0:d} of {1:d} partitions]'
                          .format(state['num_processed'], state['num_jobs']))
def _process_network_imeis_result ( self , state , future ) : future . result ( ) state [ 'num_processed' ] += 1 self . _logger . info ( 'Updated network_imeis table with unseen imeis [{0:d} of {1:d} partitions]' . format ( state [ 'num_processed' ] , state [ 'num_jobs' ] ) )
Process a network_imeis future, mutating the passed state.
Process a network_imeis future mutating the passed state .
"""Process a network_imeis future, mutating the passed state.""" # will throw exception if this one was thrown in thread
self
state
future